Module barrier_manager

Re-exports

pub use progress::CreateMviewProgressReporter;

Modules

await_epoch_completed_future 🔒

managed_state 🔒

progress 🔒

Structs

BarrierCompleteResult

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

ControlStreamHandle 🔒

EventSender 🔒

LocalBarrierManager

LocalBarrierWorker 🔒

LocalBarrierWorker manages barrier control flow, used by local stream manager. Specifically, LocalBarrierWorker serve barrier injection from meta server, send the barriers to and collect them from all actors, and finally report the progress.

LocalBarrierWorkerDebugInfo 🔒

StreamActorManager 🔒

Enums

LocalActorOperation 🔒

LocalBarrierEvent 🔒

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 🔒

Type Aliases

ScoredStreamError 🔒

A StreamError with a score, used to find the root cause of actor failures.