Struct dataflow::source::SourceMessage

pub struct SourceMessage<Key, Value> {
    pub partition: PartitionId,
    pub offset: MzOffset,
    pub upstream_time_millis: Option<i64>,
    pub key: Key,
    pub value: Value,
}

Source-agnostic wrapper for messages. Each source must implement a conversion to Message.

Fields

partition: PartitionId

Partition from which this message originates

offset: MzOffset

Materialize offset of the message (1-indexed)

upstream_time_millis: Option<i64>

The time that an external system first observed the message

Milliseconds since the unix epoch

key: Key

The message key

value: Value

The message value

Trait Implementations

impl Debug for SourceMessage<(), MessagePayload>

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

Formats the value using the given formatter.

impl Debug for SourceMessage<Option<Vec<u8>>, Option<Vec<u8>>>

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

Formats the value using the given formatter.

impl<'a> From<&'_ BorrowedMessage<'a>> for SourceMessage<Option<Vec<u8>>, Option<Vec<u8>>>

fn from(msg: &BorrowedMessage<'a>) -> Self

Performs the conversion.