Module command 

Structs

BatchRefreshInfo

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

SinceEpochInfo

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

Functions

sink_original_schema_fields 🔒

Type Aliases

SinceTimestampResolvedEpoch

TableLogEpochs

UpstreamTableLogEpochs