Module command 

Structs

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 via corresponding *_to_mutation helpers, and may do different stuffs after the barrier is collected.

CreateStreamingJobType

PostCollectCommand

ResumeBackfillTarget