Enum FragmentTypeFlag 

#[repr(u32)]
pub enum FragmentTypeFlag {
    Source = 1,
    Mview = 2,
    Sink = 4,
    Now = 8,
    StreamScan = 16,
    BarrierRecv = 32,
    Values = 64,
    Dml = 128,
    CdcFilter = 256,
    Skipped1 = 512,
    SourceScan = 1_024,
    SnapshotBackfillStreamScan = 2_048,
    FsFetch = 4_096,
    CrossDbSnapshotBackfillStreamScan = 8_192,
    StreamCdcScan = 16_384,
    VectorIndexWrite = 32_768,
    UpstreamSinkUnion = 65_536,
    LocalityProvider = 131_072,
}

Variants

Source = 1

Mview = 2

Sink = 4

Now = 8

StreamScan = 16

BarrierRecv = 32

Values = 64

Dml = 128

CdcFilter = 256

Skipped1 = 512

SourceScan = 1_024

SnapshotBackfillStreamScan = 2_048

FsFetch = 4_096

CrossDbSnapshotBackfillStreamScan = 8_192

StreamCdcScan = 16_384

VectorIndexWrite = 32_768

UpstreamSinkUnion = 65_536

LocalityProvider = 131_072

Implementations

impl FragmentTypeFlag

pub fn as_str_name(&self) -> &'static str

impl FragmentTypeFlag

pub fn raw_flag(flags: impl IntoIterator<Item = FragmentTypeFlag>) -> u32

pub fn backfill_rate_limit_fragments() -> impl Iterator<Item = FragmentTypeFlag>

Fragments that may be affected by BACKFILL_RATE_LIMIT.

pub fn source_rate_limit_fragments() -> impl Iterator<Item = FragmentTypeFlag>

Fragments that may be affected by SOURCE_RATE_LIMIT. Note: for FsFetch, old fragments don’t have this flag set, so don’t use this to check.

pub fn sink_rate_limit_fragments() -> impl Iterator<Item = FragmentTypeFlag>

Fragments that may be affected by BACKFILL_RATE_LIMIT.

pub fn rate_limit_fragments() -> impl Iterator<Item = FragmentTypeFlag>

Note: this doesn’t include FsFetch created in old versions.

pub fn dml_rate_limit_fragments() -> impl Iterator<Item = FragmentTypeFlag>

Trait Implementations

impl Clone for FragmentTypeFlag

fn clone(&self) -> FragmentTypeFlag

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FragmentTypeFlag

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for FragmentTypeFlag

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Hash for FragmentTypeFlag

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for FragmentTypeFlag

fn eq(&self, other: &FragmentTypeFlag) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialOrd for FragmentTypeFlag

fn partial_cmp(&self, other: &FragmentTypeFlag) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl TryFrom<u32> for FragmentTypeFlag

type Error = String

The type returned in the event of a conversion error.

fn try_from(value: u32) -> Result<Self, Self::Error>

Performs the conversion.

impl Copy for FragmentTypeFlag

impl Eq for FragmentTypeFlag

impl StructuralPartialEq for FragmentTypeFlag