Struct PendingSyncBatch 

pub struct PendingSyncBatch {
    pub key: SyncBucketKey,
    pub committed_state: SyncBucketState,
    pub payload: Vec<u8>,
}

Durable write-ahead record for one fetched update batch. The opaque payload is owned by the sync engine and retained until reducer writes and the bucket cursor have both committed.

Fields

key: SyncBucketKey

Bucket receiving the batch.

committed_state: SyncBucketState

Cursor to commit after the batch is reapplied successfully.

payload: Vec<u8>

Versioned opaque encoded updates and sidecars.

Trait Implementations

impl Clone for PendingSyncBatch

fn clone(&self) -> PendingSyncBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingSyncBatch

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

Formats the value using the given formatter.

impl Eq for PendingSyncBatch

impl PartialEq for PendingSyncBatch

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for PendingSyncBatch