Module command

Structs

• CommandContext 🔒
  CommandContext is used for generating barrier and doing post stuffs according to the given Command.
• CreateStreamingJobCommandInfo
• ReplaceStreamJobPlan
  Replacing an old job with a new one. All actors in the job will be rebuilt.
• Reschedule
  Reschedule is for the Command::RescheduleFragment, which is used for rescheduling actors in some fragment, like scaling or migrating.
• SnapshotBackfillInfo

Enums

• BarrierKind
• 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