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 🔒
• ScoredStreamError 🔒
  A StreamError with a score, used to find the root cause of actor failures.
• 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 🔒