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 describes per-fragment changes in a resolved reschedule plan, used for actor scaling or migration.

RescheduleContext

Preloaded context for rescheduling, built outside the barrier worker.

ReschedulePlan

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

PostCollectCommand

ResumeBackfillTarget