Uses of Class
io.streamthoughts.azkarra.api.streams.State

Packages that use State

Package	Description
io.streamthoughts.azkarra.api
io.streamthoughts.azkarra.api.streams
io.streamthoughts.azkarra.api.streams.internal
io.streamthoughts.azkarra.runtime.interceptors.monitoring

Uses of State in io.streamthoughts.azkarra.api

Methods in io.streamthoughts.azkarra.api that return State

Modifier and Type	Method	Description
State	StreamsLifecycleContext.streamsState()	Gets the state value of the current streams instance.

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

Methods in io.streamthoughts.azkarra.api.streams that return State

Modifier and Type	Method	Description
State	StateChangeEvent.newState()
State	StateChangeEvent.oldState()
static State	State.valueOf(String name)	Returns the enum constant of this type with the specified name.
static State[]	State.values()	Returns an array containing the constants of this enum type, in the order they are declared.

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.

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 given State.
void	KafkaStreamsContainer.setState(State state)

Constructors in io.streamthoughts.azkarra.api.streams with parameters of type State

Constructor	Description
StateChangeEvent(long timestamp, State newState, State oldState)	Creates a new StateChangeEvent instance.

Uses of State in io.streamthoughts.azkarra.api.streams.internal

Methods in io.streamthoughts.azkarra.api.streams.internal that return State

Modifier and Type	Method	Description
State	InternalStreamsLifecycleContext.streamsState()	Gets the state value of the current streams instance.

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

Modifier and Type	Method	Description
void	InternalStreamsLifecycleContext.setState(State state)	Sets the state of the current streams 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)	Creates a new KafkaStreamsMetadata instance.