Enum FlowMessage 

pub enum FlowMessage<'a> {
    Probe(FlowProbe),
    State(FlowState),
    Prepare {
        epoch: ReceiveEpoch,
        batch: PrepareBatch<'a>,
    },
}

Separately typed nonvoting flow family, sharing the ordinary replica envelope.

Variants

Probe(FlowProbe)

Correlated request for receipt state.

State(FlowState)

Volatile contiguous receipt, not durability.

Prepare

Hash-validated normal data in the locally required receive epoch.

Fields

epoch: ReceiveEpoch

Receiver incarnation checked before body decoding/hashing.

batch: PrepareBatch<'a>

Borrowed canonical operations; application validation remains required.

Trait Implementations

impl<'a> Clone for FlowMessage<'a>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for FlowMessage<'a>

impl<'a> Debug for FlowMessage<'a>

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

Formats the value using the given formatter.

impl<'a> Eq for FlowMessage<'a>

impl<'a> PartialEq for FlowMessage<'a>

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

Equality operator ==.

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

Inequality operator !=.

impl<'a> StructuralPartialEq for FlowMessage<'a>