Uses of Interface
io.streamthoughts.azkarra.api.StreamsLifecycleInterceptor

Packages that use StreamsLifecycleInterceptor

Package	Description
io.streamthoughts.azkarra.api
io.streamthoughts.azkarra.api.streams
io.streamthoughts.azkarra.api.streams.topology
io.streamthoughts.azkarra.metrics.interceptor
io.streamthoughts.azkarra.runtime.context.internal
io.streamthoughts.azkarra.runtime.env
io.streamthoughts.azkarra.runtime.interceptors
io.streamthoughts.azkarra.runtime.streams.topology

Uses of StreamsLifecycleInterceptor in io.streamthoughts.azkarra.api

Fields in io.streamthoughts.azkarra.api with type parameters of type StreamsLifecycleInterceptor

Modifier and Type	Field	Description
protected List<Supplier<StreamsLifecycleInterceptor>>	Executed.interceptors

Method parameters in io.streamthoughts.azkarra.api with type arguments of type StreamsLifecycleInterceptor

Modifier and Type	Method	Description
StreamsExecutionEnvironment	StreamsExecutionEnvironment.addStreamsLifecycleInterceptor(Supplier<StreamsLifecycleInterceptor> interceptor)	Adds a streams interceptor hat will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
Executed	Executed.withInterceptor(Supplier<StreamsLifecycleInterceptor> interceptor)	Returns a new Executed with the specified interceptor.
Executed	Executed.withInterceptors(List<Supplier<StreamsLifecycleInterceptor>> interceptors)	Returns a new Executed with the specified interceptors.

Uses of StreamsLifecycleInterceptor in io.streamthoughts.azkarra.api.streams

Methods in io.streamthoughts.azkarra.api.streams with parameters of type StreamsLifecycleInterceptor

Modifier and Type	Method	Description
void	InternalStreamsLifeCycleChain.Callback.execute(StreamsLifecycleInterceptor interceptor, StreamsLifecycleChain chain)

Constructor parameters in io.streamthoughts.azkarra.api.streams with type arguments of type StreamsLifecycleInterceptor

Constructor	Description
InternalStreamsLifeCycleChain(Iterator<StreamsLifecycleInterceptor> interceptors, InternalStreamsLifeCycleChain.Callback callback, Runnable runnable)	Creates a new InternalStreamsLifeCycleChain instance.

Uses of StreamsLifecycleInterceptor in io.streamthoughts.azkarra.api.streams.topology

Methods in io.streamthoughts.azkarra.api.streams.topology that return types with arguments of type StreamsLifecycleInterceptor

Modifier and Type	Method	Description
List<StreamsLifecycleInterceptor>	TopologyContainer.interceptors()

Constructor parameters in io.streamthoughts.azkarra.api.streams.topology with type arguments of type StreamsLifecycleInterceptor

Constructor	Description
TopologyContainer(org.apache.kafka.streams.Topology topology, ApplicationId applicationId, Conf streamsConfig, TopologyMetadata metadata, List<StreamsLifecycleInterceptor> interceptors)	Creates a new TopologyContainer instance.

Uses of StreamsLifecycleInterceptor in io.streamthoughts.azkarra.metrics.interceptor

Classes in io.streamthoughts.azkarra.metrics.interceptor that implement StreamsLifecycleInterceptor

Modifier and Type	Class	Description
class	MeterKafkaStreamsInterceptor

Uses of StreamsLifecycleInterceptor in io.streamthoughts.azkarra.runtime.context.internal

Methods in io.streamthoughts.azkarra.runtime.context.internal that return StreamsLifecycleInterceptor

Modifier and Type	Method	Description
StreamsLifecycleInterceptor	ContextAwareLifecycleInterceptorSupplier.get()

Constructor parameters in io.streamthoughts.azkarra.runtime.context.internal with type arguments of type StreamsLifecycleInterceptor

Constructor	Description
ContextAwareLifecycleInterceptorSupplier(AzkarraContext context, GettableComponent<StreamsLifecycleInterceptor> gettable)

Uses of StreamsLifecycleInterceptor in io.streamthoughts.azkarra.runtime.env

Method parameters in io.streamthoughts.azkarra.runtime.env with type arguments of type StreamsLifecycleInterceptor

Modifier and Type	Method	Description
StreamsExecutionEnvironment	DefaultStreamsExecutionEnvironment.addStreamsLifecycleInterceptor(Supplier<StreamsLifecycleInterceptor> interceptor)	Adds a streams interceptor hat will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.

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

Classes in io.streamthoughts.azkarra.runtime.interceptors that implement StreamsLifecycleInterceptor

Modifier and Type	Class	Description
class	AutoCreateTopicsInterceptor	This StreamsLifecycleInterceptor create both topics source and sink before starting the streams instance.
class	ClassloadingIsolationInterceptor
class	CompositeStreamsInterceptor
class	MonitoringStreamsInterceptor	Interceptor to monitor KafkaStreams instance.
class	WaitForSourceTopicsInterceptor	This StreamsLifecycleInterceptor waits for source topics to be created before starting the streams instance.

Method parameters in io.streamthoughts.azkarra.runtime.interceptors with type arguments of type StreamsLifecycleInterceptor

Modifier and Type	Method	Description
void	CompositeStreamsInterceptor.addInterceptors(Collection<StreamsLifecycleInterceptor> interceptors)

Constructor parameters in io.streamthoughts.azkarra.runtime.interceptors with type arguments of type StreamsLifecycleInterceptor

Constructor	Description
CompositeStreamsInterceptor(Collection<StreamsLifecycleInterceptor> interceptors)	Creates a new CompositeStreamsInterceptor instance.

Uses of StreamsLifecycleInterceptor in io.streamthoughts.azkarra.runtime.streams.topology

Methods in io.streamthoughts.azkarra.runtime.streams.topology that return types with arguments of type StreamsLifecycleInterceptor

Modifier and Type	Method	Description
List<Supplier<StreamsLifecycleInterceptor>>	InternalExecuted.interceptors()