risingwave_stream::task

Module stream_manager

Source

Modules§

await_tree_key

Structs§

ActorEvalErrorReport
Report expression evaluation errors to the actor context.
LocalStreamManager
LocalStreamManager directly handles public API for streaming, e.g., StreamService, ExchangeService.

Type Aliases§

ActorHandle
AtomicU64Ref