Module barrier

Modules

• checkpoint 🔒
• command 🔒
• complete_task 🔒
• context 🔒
• info 🔒
• manager 🔒
• notifier 🔒
• progress 🔒
• rpc 🔒
• schedule 🔒
• trace 🔒
• utils 🔒
• worker 🔒

Structs

• BarrierScheduler
  The sender side of the barrier scheduling queue. Can be cloned and held by other managers to schedule and run barriers.
• BarrierWorkerRuntimeInfoSnapshot 🔒
• CreateStreamingJobCommandInfo
• GlobalBarrierManager
• InflightSubscriptionInfo
• ReplaceTablePlan
  Replacing an old table with a new one. All actors in the table job will be rebuilt. Used for ALTER TABLE (Command::ReplaceTable) and sink into table (Command::CreateStreamingJob).
• Reschedule
  Reschedule is for the Command::RescheduleFragment, which is used for rescheduling actors in some fragment, like scaling or migrating.
• Scheduled 🔒
  Scheduled command with its notifiers.
• SnapshotBackfillInfo
• TracedEpoch
  A wrapper of Epoch with tracing span, used for issuing epoch-based tracing from the barrier manager on the meta service. This structure is free to clone, which’ll extend the lifetime of the underlying span.

Enums

• BarrierKind
• BarrierManagerRequest 🔒
• BarrierManagerStatus 🔒
  Status of barrier manager.
• Command
  Command is the input of crate::barrier::worker::GlobalBarrierWorker. For different commands, it will build different barriers to send, and may do different stuffs after the barrier is collected.
• CreateStreamingJobType
• RecoveryReason 🔒
  The reason why the cluster is recovering.

Type Aliases

• BarrierManagerRef