Struct DatabaseEventBatch 

pub struct DatabaseEventBatch {
    pub events: Vec<DatabaseEvent>,
    pub source_id: Option<String>,
    pub batch_seq: u64,
    pub relations: Vec<RelationMeta>,
    pub control_directive: Option<ControlDirective>,
    pub sequence_values: Option<Vec<SequenceValue>>,
    pub backfill_metadata: Option<BackfillMetadata>,
}

Batch of events for efficient transport.

Fields

events: Vec<DatabaseEvent>

Events in this batch.

source_id: Option<String>

Source identifier (proxy/connector ID).

batch_seq: u64

Batch sequence number (for ordering/deduplication).

relations: Vec<RelationMeta>

Cached relation metadata for this batch.

control_directive: Option<ControlDirective>

Control directive for this batch (if a control batch). When present, this batch signals the receiver to perform an administrative operation rather than applying data changes.

sequence_values: Option<Vec<SequenceValue>>

Sequence values for synchronization. Present when control_directive is SyncSequences.

backfill_metadata: Option<BackfillMetadata>

Backfill metadata for progress tracking. Present when the batch contains a BackfillStart event.

Implementations

impl DatabaseEventBatch

pub fn new() -> Self

Create a new empty batch.

pub fn with_events(events: Vec<DatabaseEvent>) -> Self

Create a batch with events.

pub fn control(directive: ControlDirective) -> Self

Create a control batch that signals an administrative operation.

pub fn sequence_sync(sequences: Vec<SequenceValue>) -> Self

Create a sequence sync control batch with sequence values.

pub fn with_source_id(self, source_id: impl Into<String>) -> Self

Set the source ID.

pub fn with_batch_seq(self, seq: u64) -> Self

Set the batch sequence number.

pub fn with_control_directive(self, directive: ControlDirective) -> Self

Set the control directive.

pub fn with_sequence_values(self, sequences: Vec<SequenceValue>) -> Self

Set sequence values.

pub fn with_backfill_metadata(self, metadata: BackfillMetadata) -> Self

Set backfill metadata for progress tracking.

pub fn is_control_batch(&self) -> bool

Check if this is a control batch (no data events, just a directive).

pub fn size_bytes(&self) -> usize

Estimate the size of this batch in bytes.

Trait Implementations

impl Clone for DatabaseEventBatch

fn clone(&self) -> DatabaseEventBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DatabaseEventBatch

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

Formats the value using the given formatter.

impl Default for DatabaseEventBatch

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for DatabaseEventBatch

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for DatabaseEventBatch

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for DatabaseEventBatch

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for DatabaseEventBatch