Uses of Package
io.streamthoughts.azkarra.api.events
-
Classes in io.streamthoughts.azkarra.api.events used by io.streamthoughts.azkarra.api.events Class Description BlockingRecordQueue A blocking queue that can be used for publishing key-value records from a Kafka Streams topology.EventStream A typed stream of events backed by aBlockingRecordQueue
.EventStream.Builder EventStreamPipe The EventStreamPipe is used to attached or detach an object that will be responsible to consume records send to anEventStream
.EventStreamProvider EventStreamsProvider.LimitHandler The default interface to be used for executing logic when buffer limit is reached. -
Classes in io.streamthoughts.azkarra.api.events used by io.streamthoughts.azkarra.api.events.callback Class Description BlockingRecordQueue A blocking queue that can be used for publishing key-value records from a Kafka Streams topology.LimitHandler The default interface to be used for executing logic when buffer limit is reached. -
Classes in io.streamthoughts.azkarra.api.events used by io.streamthoughts.azkarra.api.events.reactive Class Description EventStream A typed stream of events backed by aBlockingRecordQueue
. -
Classes in io.streamthoughts.azkarra.api.events used by io.streamthoughts.azkarra.api.streams Class Description EventStream A typed stream of events backed by aBlockingRecordQueue
. -
Classes in io.streamthoughts.azkarra.api.events used by io.streamthoughts.azkarra.api.streams.topology Class Description EventStream A typed stream of events backed by aBlockingRecordQueue
. -
Classes in io.streamthoughts.azkarra.api.events used by io.streamthoughts.azkarra.runtime.context.internal Class Description EventStream A typed stream of events backed by aBlockingRecordQueue
.EventStreamProvider EventStreamsProvider. -
Classes in io.streamthoughts.azkarra.api.events used by io.streamthoughts.azkarra.runtime.streams Class Description EventStream A typed stream of events backed by aBlockingRecordQueue
. -
Classes in io.streamthoughts.azkarra.api.events used by io.streamthoughts.examples.azkarra.sse Class Description EventStreamProvider EventStreamsProvider.EventStreamSupport Base class forEventStreamProvider
.