Module dispatch_sync_log_store

risingwave_stream::executor::dispatch

Module dispatch_sync_log_store 

Source

Structs§

SyncLogStoreDispatchExecutor
Executor that pairs a synced KV log store with a dispatcher so the log store can advance and write independently of downstream backpressure.

Enums§

ConsumerFuture 🔒
State machine for the consumer side, which reads chunks from the log store and dispatches chunks or barriers downstream.
ConsumerFutureEvent 🔒
ConsumerFutureProj 🔒
ConsumerFutureProjReplace 🔒

Functions§

dispatching_future 🔒

Type Aliases§

DispatchingFuture 🔒