Struct ColumnAssignment 

pub struct ColumnAssignment {
    pub column: String,
    pub index: i16,
    pub retired: bool,
}

One source column’s pinned replicate index, as the API’s register response reports it (and as stream metadata persists it under replicates.assignments). Sync services assign each value’s replicate_index by looking its source column up here.

Fields

column: String

index: i16

retired: bool

The source no longer sends this column. The index stays reserved and remains the column’s identity should it reappear.

Implementations

impl ColumnAssignment

pub fn from_metadata(metadata: &Value) -> Option<Vec<Self>>

The mapping a stream’s metadata carries, resolved the way the API resolves it. None when the stream declares no replicate family.

pub fn resolve(pinned: Vec<Self>, source_columns: &[String]) -> Vec<Self>

The authoritative mapping, ordered by index: the assignments the API pinned, or, on a spec stored before pinning, each declared source column at its position, which is the index its readings were stored under. Both crates read an unpinned spec through here so that neither invents an index the other would not.

Trait Implementations

impl Clone for ColumnAssignment

fn clone(&self) -> ColumnAssignment

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ColumnAssignment

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ColumnAssignment

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ColumnAssignment

impl PartialEq for ColumnAssignment

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ColumnAssignment

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 ColumnAssignment