Uses of Interface
io.streamthoughts.azkarra.api.StreamsLifecycleChain
-
-
Uses of StreamsLifecycleChain in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api with parameters of type StreamsLifecycleChain Modifier and Type Method Description default void
StreamsLifecycleInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.default void
StreamsLifecycleInterceptor. onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being stopped. -
Uses of StreamsLifecycleChain in io.streamthoughts.azkarra.api.streams
Classes in io.streamthoughts.azkarra.api.streams that implement StreamsLifecycleChain Modifier and Type Class Description class
InternalStreamsLifeCycleChain
Methods in io.streamthoughts.azkarra.api.streams with parameters of type StreamsLifecycleChain Modifier and Type Method Description void
InternalStreamsLifeCycleChain.Callback. execute(StreamsLifecycleInterceptor interceptor, StreamsLifecycleChain chain)
-
Uses of StreamsLifecycleChain in io.streamthoughts.azkarra.metrics.interceptor
Methods in io.streamthoughts.azkarra.metrics.interceptor with parameters of type StreamsLifecycleChain Modifier and Type Method Description void
MeterKafkaStreamsInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.void
MeterKafkaStreamsInterceptor. onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being stopped. -
Uses of StreamsLifecycleChain in io.streamthoughts.azkarra.runtime.interceptors
Methods in io.streamthoughts.azkarra.runtime.interceptors with parameters of type StreamsLifecycleChain Modifier and Type Method Description void
AutoCreateTopicsInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.void
ClassloadingIsolationInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.void
CompositeStreamsInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.void
MonitoringStreamsInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.void
WaitForSourceTopicsInterceptor. onStart(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being started.void
AutoCreateTopicsInterceptor. onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being stopped.void
CompositeStreamsInterceptor. onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being stopped.void
MonitoringStreamsInterceptor. onStop(StreamsLifecycleContext context, StreamsLifecycleChain chain)
Intercepts the streams instance before being stopped.
-