Enum mz_dataflow_types::sources::DebeziumSourceProjection

pub enum DebeziumSourceProjection {
    MySql {
        file: usize,
        pos: usize,
        row: usize,
    },
    Postgres {
        sequence: 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 connection 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: usize

lsn: usize

SqlServer

Fields

change_lsn: usize

event_serial_no: usize

Trait Implementations

impl Arbitrary for DebeziumSourceProjection

type Parameters = ((<usize as Arbitrary>::Parameters, <usize as Arbitrary>::Parameters, <usize as Arbitrary>::Parameters), (<usize as Arbitrary>::Parameters, <usize as Arbitrary>::Parameters), (<usize as Arbitrary>::Parameters, <usize as Arbitrary>::Parameters))

The type of parameters that arbitrary_with accepts for configuration of the generated Strategy. Parameters must implement Default.

type Strategy = TupleUnion<((u32, Arc<Map<(<usize as Arbitrary>::Strategy, <usize as Arbitrary>::Strategy, <usize as Arbitrary>::Strategy), fn(_: (usize, usize, usize)) -> Self>>), (u32, Arc<Map<(<usize as Arbitrary>::Strategy, <usize as Arbitrary>::Strategy), fn(_: (usize, usize)) -> Self>>), (u32, Arc<Map<(<usize as Arbitrary>::Strategy, <usize as Arbitrary>::Strategy), fn(_: (usize, usize)) -> Self>>))>

The type of Strategy used to generate values of type Self.

fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self). The strategy is passed the arguments given in args.

fn arbitrary() -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self).

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 RustType<ProtoDebeziumSourceProjection> for DebeziumSourceProjection

fn into_proto(&self) -> ProtoDebeziumSourceProjection

Convert a Self into a Proto value.

fn from_proto(
    proto: ProtoDebeziumSourceProjection
) -> Result<Self, TryFromProtoError>

Consume and convert a Proto back into a Self value.

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