Module command

Structs

• CommandContext 🔒
  CommandContext is used for generating barrier and doing post stuffs according to the given Command.
• CreateStreamingJobCommandInfo
• 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.
• 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