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