Uses of Interface
io.streamthoughts.azkarra.api.StreamsLifecycleContext
-
-
Uses of StreamsLifecycleContext in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api with parameters of type StreamsLifecycleContext 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 StreamsLifecycleContext in io.streamthoughts.azkarra.api.streams.internal
Classes in io.streamthoughts.azkarra.api.streams.internal that implement StreamsLifecycleContext Modifier and Type Class Description class
InternalStreamsLifecycleContext
InternalStreamsLifecycleContext
implementation. -
Uses of StreamsLifecycleContext in io.streamthoughts.azkarra.metrics.interceptor
Methods in io.streamthoughts.azkarra.metrics.interceptor with parameters of type StreamsLifecycleContext 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 StreamsLifecycleContext in io.streamthoughts.azkarra.runtime.interceptors
Methods in io.streamthoughts.azkarra.runtime.interceptors with parameters of type StreamsLifecycleContext 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.
-