Struct TransactionRegistrationStateFacts 

pub struct TransactionRegistrationStateFacts {
    pub state_allows_registration: bool,
    pub state_is_ongoing: bool,
    pub exact_partitions_registered: bool,
}

Fields

state_allows_registration: bool

state_is_ongoing: bool

Kafka’s txnMetadata.state == ONGOING. The retry optimization below applies only in that exact state, never against a stale partition set left over from a completed or not-yet-started transaction.

exact_partitions_registered: bool

Trait Implementations

impl Clone for TransactionRegistrationStateFacts

fn clone(&self) -> TransactionRegistrationStateFacts

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for TransactionRegistrationStateFacts

impl Debug for TransactionRegistrationStateFacts

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

Formats the value using the given formatter.

impl Eq for TransactionRegistrationStateFacts

impl PartialEq for TransactionRegistrationStateFacts

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for TransactionRegistrationStateFacts