Struct PkTuple 

pub struct PkTuple(pub Vec<Value>);

An ordered tuple of primary key values.

The values are ordered to match the corresponding TableSpec::pk_columns so single and composite primary keys are handled uniformly.

Tuple Fields

0: Vec<Value>

Implementations

impl PkTuple

pub fn new(values: Vec<Value>) -> Self

Create a primary key tuple from ordered values.

pub fn key(&self) -> String

A stable string key for this primary key, suitable for use as a hash map key (works for composite keys and value kinds that are not themselves Hash/Eq).

Values are canonicalized before serialization so snapshot reads and CDC events that differ only by integer width (Int32 vs Int64) or string kind (VarChar vs Text) still collide for window dedup.

pub fn single_uuid(&self) -> Option<Uuid>

If this is a single-column UUID key, return the UUID.

The framework writes watermarks as rows keyed by a freshly generated UUID and recognizes those rows in the change stream via this helper.

pub fn from_row(row: &Row, pk_columns: &[String]) -> Result<Self>

Extract the primary key tuple from a row given the table’s primary key columns.

Each column is looked up in the row’s fields. As a convenience for single-column primary keys, a missing field falls back to the row’s dedicated id value. Extracted values are canonicalized so they match Self::key used for window dedup.

Trait Implementations

impl Clone for PkTuple

fn clone(&self) -> PkTuple

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PkTuple

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PkTuple

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for PkTuple

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for PkTuple

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 PkTuple