Trait ChangeEvent

pub trait ChangeEvent {
    // Required methods
    fn op(&self) -> AccessResult<ChangeEventOperation>;
    fn access_field(
        &self,
        desc: &SourceColumnDesc,
    ) -> AccessResult<DatumCow<'_>>;
}

Methods to access a CDC event.

Required Methods

fn op(&self) -> AccessResult<ChangeEventOperation>

Access the operation type.

fn access_field(&self, desc: &SourceColumnDesc) -> AccessResult<DatumCow<'_>>

Access the field.

Implementations on Foreign Types

impl<'a, T: 'a + ChangeEvent + ?Sized> ChangeEvent for &'a T

fn op(&self) -> AccessResult<ChangeEventOperation>

fn access_field(&self, desc: &SourceColumnDesc) -> AccessResult<DatumCow<'_>>

impl<A> ChangeEvent for (ChangeEventOperation, A)

where A: Access,

fn op(&self) -> AccessResult<ChangeEventOperation>

fn access_field(&self, desc: &SourceColumnDesc) -> AccessResult<DatumCow<'_>>

Implementors

impl<A> ChangeEvent for DebeziumChangeEvent<A>

where A: Access,

impl<A> ChangeEvent for MaxwellChangeEvent<A>

where A: Access,