Struct SourceEnvelope 

pub struct SourceEnvelope {
    pub record: SourceRecord,
    pub offset: Option<Offset>,
}

A source record together with optional checkpoint information.

This struct represents a single record emitted by a source connector, along with optional checkpoint information.

Fields

record: SourceRecord

The record to publish to Danube.

offset: Option<Offset>

Optional offset/checkpoint to commit after successful publish.

Implementations

impl SourceEnvelope

pub fn new(record: SourceRecord) -> Self

Create an envelope without checkpoint information.

pub fn with_offset(record: SourceRecord, offset: Offset) -> Self

Create an envelope with an offset to commit after successful delivery.

pub fn record(&self) -> &SourceRecord

Borrow the record carried by this envelope.

pub fn offset(&self) -> Option<&Offset>

Borrow the offset carried by this envelope, if present.

pub fn into_parts(self) -> (SourceRecord, Option<Offset>)

Split this envelope into its record and optional offset parts.

Trait Implementations

impl Clone for SourceEnvelope

fn clone(&self) -> SourceEnvelope

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceEnvelope

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

Formats the value using the given formatter.

impl From<SourceRecord> for SourceEnvelope

fn from(record: SourceRecord) -> Self

Converts to this type from the input type.