Type Alias PbStreamScanType 

pub type PbStreamScanType = StreamScanType;

Aliased Type

#[repr(i32)]
pub enum PbStreamScanType {
    Unspecified = 0,
    Chain = 1,
    Rearrange = 2,
    Backfill = 3,
    UpstreamOnly = 4,
    ArrangementBackfill = 5,
    SnapshotBackfill = 6,
    CrossDbSnapshotBackfill = 7,
}

Variants

Unspecified = 0

Chain = 1

👎Deprecated

ChainExecutor. Deprecated: only for existing persisted legacy jobs.

Rearrange = 2

👎Deprecated

RearrangedChainExecutor. Deprecated: only for existing persisted legacy jobs.

Backfill = 3

👎Deprecated

BackfillExecutor. Deprecated: only for existing persisted legacy jobs.

UpstreamOnly = 4

ChainExecutor with upstream_only = true

ArrangementBackfill = 5

ArrangementBackfillExecutor

SnapshotBackfill = 6

SnapshotBackfillExecutor

CrossDbSnapshotBackfill = 7

SnapshotBackfillExecutor

Implementations

impl PbStreamScanType

pub fn is_reschedulable(&self, is_online: bool) -> bool