Enum TopologyInitialization 

pub enum TopologyInitialization {
    PreserveExactCut,
    FutureOnlyAtCut,
    EmptyManagedStateAtCut,
    ResolveSourcePositionsOnce,
    RetireAtCut,
    SeedFromUpstreamAtCut,
}

Required initialization semantics. These are requirements, never concrete cut positions.

Variants

PreserveExactCut

Retain the exact reconciled cut’s state, timers, watermarks and source/output progress.

FutureOnlyAtCut

Process only target-generation input after the cut, without historical replay or backfill.

EmptyManagedStateAtCut

Initialize new managed state empty at the exact cut; consume only subsequent input. This never authorizes resetting a preserved operator or a target checkpoint image.

ResolveSourcePositionsOnce

Resolve concrete latest source/partition positions once at the cut and persist before commit.

RetireAtCut

Settle old-generation state/progress/effects at the cut and omit the object from the target.

SeedFromUpstreamAtCut

Initialize a new materialized view’s managed state empty at the exact cut, then apply the rows its preserved upstream changelog holds at the cut before any subsequent input.

Implementations

impl TopologyInitialization

pub const fn starts_empty_at_cut(self) -> bool

Whether the object’s managed state starts empty at the cut.

Trait Implementations

impl Clone for TopologyInitialization

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for TopologyInitialization

impl Debug for TopologyInitialization

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TopologyInitialization

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for TopologyInitialization

impl PartialEq for TopologyInitialization

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for TopologyInitialization

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for TopologyInitialization