Uses of Interface
io.streamthoughts.azkarra.api.streams.State
-
-
Uses of State in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api that return State Modifier and Type Method Description default State
StreamsLifecycleContext. streamsState()
Methods in io.streamthoughts.azkarra.api with parameters of type State Modifier and Type Method Description void
StreamsLifecycleContext. setState(State state)
Sets the state of the current streams instance. -
Uses of State in io.streamthoughts.azkarra.api.streams
Classes in io.streamthoughts.azkarra.api.streams that implement State Modifier and Type Class Description static class
State.Standards
The standardState
for aKafkaStreams
instance.Methods in io.streamthoughts.azkarra.api.streams that return State Modifier and Type Method Description State
StateChangeEvent. newState()
State
StateChangeEvent. oldState()
Methods in io.streamthoughts.azkarra.api.streams that return types with arguments of type State Modifier and Type Method Description TimestampedValue<State>
KafkaStreamsContainer. state()
Gets the current state of the streams container.Methods in io.streamthoughts.azkarra.api.streams with parameters of type State Modifier and Type Method Description default boolean
KafkaStreamsContainer.StateChangeWatcher. accept(State newState)
Should this watcher be called for the givenState
.Constructors in io.streamthoughts.azkarra.api.streams with parameters of type State Constructor Description StateChangeEvent(long timestamp, State newState, State oldState)
Creates a newStateChangeEvent
instance.StateChangeEvent(State newState, State oldState)
Creates a newStateChangeEvent
instance. -
Uses of State in io.streamthoughts.azkarra.runtime.interceptors.monitoring
Methods in io.streamthoughts.azkarra.runtime.interceptors.monitoring that return State Modifier and Type Method Description State
KafkaStreamsMetadata. state()
Constructor parameters in io.streamthoughts.azkarra.runtime.interceptors.monitoring with type arguments of type State Constructor Description KafkaStreamsMetadata(TimestampedValue<State> state, Set<org.apache.kafka.streams.processor.ThreadMetadata> threads, ConsumerGroupOffsets offsets, List<LocalStatePartitionsInfo> stores)
Creates a newKafkaStreamsMetadata
instance. -
Uses of State in io.streamthoughts.azkarra.runtime.streams
Methods in io.streamthoughts.azkarra.runtime.streams that return types with arguments of type State Modifier and Type Method Description Future<State>
LocalKafkaStreamsContainer. start(Executor executor)
Asynchronously start the underlyingKafkaStreams
instance.TimestampedValue<State>
LocalKafkaStreamsContainer. state()
Gets the current state of the streams container.Methods in io.streamthoughts.azkarra.runtime.streams with parameters of type State Modifier and Type Method Description void
LocalKafkaStreamsContainer. setState(State newState)
Sets the current state of the streams.
-