Struct TopologySourceInitialization 

pub struct TopologySourceInitialization {
    pub name: String,
    pub catalog_generation: u64,
    pub compatibility_sha256: String,
    pub checkpoint: ConnectorCheckpoint,
}

One new catalog incarnation’s exact position before any participant consumes input. The existing connector cursor encoding preserves never-read partitions without inventing a consumed offset, checkpoint attempt or assignment ownership. Target installation must validate this cursor through the connector and adopt only its assigned channels before releasing intake.

Fields

name: String

Canonical source identity from the independently certified candidate.

catalog_generation: u64

New catalog incarnation, distinct from the source’s connector cursor format.

compatibility_sha256: String

Exact definition/schema/connector/dependency contract certified by every participant.

checkpoint: ConnectorCheckpoint

Complete global input inventory and numeric initial cursors supplied by the connector.

Trait Implementations

impl Clone for TopologySourceInitialization

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopologySourceInitialization

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TopologySourceInitialization

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for TopologySourceInitialization

impl PartialEq for TopologySourceInitialization

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for TopologySourceInitialization

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 TopologySourceInitialization