Enum dataflow_types::types::sources::DebeziumSourceProjection

pub enum DebeziumSourceProjection {
    MySql {
        file: usize,
        pos: usize,
        row: usize,
    },
    Postgres {
        sequence: Option<usize>,
        lsn: usize,
    },
    SqlServer {
        change_lsn: usize,
        event_serial_no: usize,
    },
}

Debezium generates records that contain metadata about the upstream database. The structure of this metadata depends on the type of connector used. This struct records the relevant indices in the record, calculated during planning, so that the dataflow operator can unpack the structure and extract the relevant information.

Variants

MySql

Fields

file: usize

pos: usize

row: usize

Postgres

Fields

sequence: Option<usize>

lsn: usize

SqlServer

Fields

change_lsn: usize

event_serial_no: usize

Trait Implementations

impl Clone for DebeziumSourceProjection

fn clone(&self) -> DebeziumSourceProjection

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DebeziumSourceProjection

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DebeziumSourceProjection

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl PartialEq<DebeziumSourceProjection> for DebeziumSourceProjection

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl Serialize for DebeziumSourceProjection

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

Serialize this value into the given Serde serializer.

impl Eq for DebeziumSourceProjection

impl StructuralEq for DebeziumSourceProjection

impl StructuralPartialEq for DebeziumSourceProjection