Module barrier_worker 

Modules

await_epoch_completed_future 🔒

managed_state

Structs

BarrierCompleteResult

Collect result of some barrier on current compute node. Will be reported to the meta service in LocalBarrierWorker::on_epoch_completed.

ControlStreamHandle 🔒

Lives in crate::task::barrier_worker::LocalBarrierWorker, Communicates with ControlStreamManager in meta. Handles [risingwave_pb::stream_service::streaming_control_stream_request::Request].

EventSender 🔒

LocalBarrierWorker 🔒

LocalBarrierWorker manages barrier control flow. Specifically, LocalBarrierWorker serves barrier injection from meta server, sends the barriers to and collects them from all actors, and finally reports the progress.

LocalBarrierWorkerDebugInfo 🔒

Enums

LocalActorOperation 🔒

Sent from crate::task::stream_manager::LocalStreamManager to crate::task::barrier_worker::LocalBarrierWorker::run.

NewOutputRequest 🔒

Constants

ENABLE_BARRIER_AGGREGATION

If enabled, all actors will be grouped in the same tracing span within one epoch. Note that this option will significantly increase the overhead of tracing.

Functions

sync_epoch 🔒