Modules§
- checkpoint 🔒
- command 🔒
- complete_
task 🔒 - context 🔒
- edge_
builder 🔒 - info 🔒
- manager 🔒
- notifier 🔒
- progress 🔒
- rpc 🔒
- schedule 🔒
- trace 🔒
- utils 🔒
- worker 🔒
Structs§
- Barrier
Scheduler - The sender side of the barrier scheduling queue. Can be cloned and held by other managers to schedule and run barriers.
- Barrier
Worker 🔒Runtime Info Snapshot - Create
Streaming JobCommand Info - Database
Runtime 🔒Info Snapshot - Global
Barrier Manager - Inflight
Subscription Info - Replace
Stream JobPlan - Replacing an old job with a new one. All actors in the job will be rebuilt.
- Reschedule
Rescheduleis for theCommand::RescheduleFragment, which is used for rescheduling actors in some fragment, like scaling or migrating.- Scheduled 🔒
- Scheduled command with its notifiers.
- Snapshot
Backfill Info - Traced
Epoch - 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§
- Barrier
Kind - Barrier
Manager 🔒Request - Barrier
Manager 🔒Status - Status of barrier manager.
- Command
Commandis the input ofcrate::barrier::worker::GlobalBarrierWorker. For different commands, it will build different barriers to send, and may do different stuffs after the barrier is collected.- Create
Streaming JobType - Recovery
Reason 🔒 - The reason why the cluster is recovering.