Uses of Interface
io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsExtension

Packages that use CloudEventsExtension

Package	Description
io.streamthoughts.azkarra.runtime.interceptors
io.streamthoughts.azkarra.runtime.interceptors.monitoring
io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce

Uses of CloudEventsExtension in io.streamthoughts.azkarra.runtime.interceptors

Methods in io.streamthoughts.azkarra.runtime.interceptors that return CloudEventsExtension

Modifier and Type	Method	Description
CloudEventsExtension	MonitoringStreamsInterceptorConfig.getExtensions()	Get the list of extension attributes that should be included in monitoring events.

Uses of CloudEventsExtension in io.streamthoughts.azkarra.runtime.interceptors.monitoring

Methods in io.streamthoughts.azkarra.runtime.interceptors.monitoring that return CloudEventsExtension

Modifier and Type	Method	Description
CloudEventsExtension	StreamsExtensionBuilder.build()

Constructors in io.streamthoughts.azkarra.runtime.interceptors.monitoring with parameters of type CloudEventsExtension

Constructor	Description
MonitoringStreamsTask(String applicationId, String applicationServer, CloudEventsExtension customExtensions, MonitoringStreamsTask.Reportable<? extends KafkaStreamsMetadata> reportable, long intervalMs, org.apache.kafka.clients.producer.Producer<byte[],byte[]> producer, String topic)	Creates a new MonitoringStreamsTask instance.

Uses of CloudEventsExtension in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce

Methods in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce that return CloudEventsExtension

Modifier and Type	Method	Description
static CloudEventsExtension	CloudEventsExtension.of(String key, Object value)

Methods in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce with parameters of type CloudEventsExtension

Modifier and Type	Method	Description
CloudEventsBuilder<T>	CloudEventsBuilder.withExtension(CloudEventsExtension extension)

Method parameters in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce with type arguments of type CloudEventsExtension

Modifier and Type	Method	Description
static Map<String,Object>	CloudEventsExtension.marshal(Collection<CloudEventsExtension> extensions)