Enum TxnDataState 

pub enum TxnDataState {
    NotTransactional,
    DataSurvives,
    DataFullyGone,
}

Whether the cleaner read data of a control marker’s own transaction in this pass. This is Kafka’s per-transaction rule (CleanedTransactionMetadata), not a per-producer one.

Variants

NotTransactional

producer_id < 0: not a transactional producer.

DataSurvives

The pass read at least one batch of this marker’s transaction, so the marker stays.

DataFullyGone

The pass read no batch of this marker’s transaction, so the marker may age out through the delete horizon.

Trait Implementations

impl Clone for TxnDataState

fn clone(&self) -> TxnDataState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for TxnDataState

impl Debug for TxnDataState

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

Formats the value using the given formatter.

impl Eq for TxnDataState

impl PartialEq for TxnDataState

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for TxnDataState