Enum mz_dataflow_types::sources::DebeziumMode

pub enum DebeziumMode {
    None,
    Ordered(DebeziumDedupProjection),
    Full(DebeziumDedupProjection),
    FullInRange {
        projection: DebeziumDedupProjection,
        pad_start: Option<NaiveDateTime>,
        start: NaiveDateTime,
        end: NaiveDateTime,
    },
}

Ordered means we can trust Debezium high water marks

In standard operation, Debezium should always emit messages in position order, but messages may be duplicated.

For example, this is a legal stream of Debezium event positions:

1 2 3 2

Note that 2 appears twice, but the first time it appeared it appeared in order. Any position below the highest-ever seen position is guaranteed to be a duplicate, and can be ignored.

Now consider this stream:

1 3 2

In this case, 2 is sent out of order, and if it is ignored we will miss important state.

It is possible for users to do things with multiple databases and multiple Debezium instances pointing at the same Kafka topic that mean that the Debezium guarantees do not hold, in which case we are required to track individual messages, instead of just the highest-ever-seen message.

Variants

None

Do not perform any deduplication

Ordered(DebeziumDedupProjection)

We can trust high water mark

Full(DebeziumDedupProjection)

We need to store some piece of state for every message

FullInRange

Fields

projection: DebeziumDedupProjection

pad_start: Option<NaiveDateTime>

start: NaiveDateTime

end: NaiveDateTime

Implementations

impl DebeziumMode

pub fn tx_metadata(&self) -> Option<&DebeziumTransactionMetadata>

Trait Implementations

impl Arbitrary for DebeziumMode

type Strategy = BoxedStrategy<Self>

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

type Parameters = ()

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

fn arbitrary_with(_: 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 DebeziumMode

fn clone(&self) -> DebeziumMode

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DebeziumMode

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DebeziumMode

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

Deserialize this value from the given Serde deserializer.

impl PartialEq<DebeziumMode> for DebeziumMode

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

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

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

This method tests for !=.

impl RustType<ProtoDebeziumMode> for DebeziumMode

fn into_proto(&self) -> ProtoDebeziumMode

Convert a Self into a Proto value.

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

Consume and convert a Proto back into a Self value.

impl Serialize for DebeziumMode

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 DebeziumMode

impl StructuralEq for DebeziumMode

impl StructuralPartialEq for DebeziumMode