Struct BatchMeta 

pub struct BatchMeta {
    pub is_control: bool,
    pub producer_id: i64,
    pub existing_horizon: Option<i64>,
}

Per-batch facts the retain decision needs.

Fields

is_control: bool

Whether the batch is a transactional control batch.

producer_id: i64

Producer id for transactional batches. It is negative for non-transactional batches.

existing_horizon: Option<i64>

The batch’s existing delete horizon, which is base_timestamp when bit 6 is set. It is None if the batch has never been stamped.

Trait Implementations

impl Clone for BatchMeta

fn clone(&self) -> BatchMeta

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BatchMeta

impl Debug for BatchMeta

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

Formats the value using the given formatter.

impl Eq for BatchMeta

impl PartialEq for BatchMeta

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for BatchMeta