Struct ManagedReadEnvelope 

pub struct ManagedReadEnvelope {
    pub v: u32,
    pub read: Vec<u8>,
    pub min_position: Option<MutationPosition>,
    pub log_head: bool,
    pub min_sessions: Vec<SessionPosition>,
}

A managed read sent with a consistency requirement. Unknown fields are refused, so no plain read request is ever taken for this frame.

With min_position, the answering node serves the read only once its fold for the read’s surface has applied that position. A client sends the highest position it has seen for the surface, so a read never misses its own earlier writes or goes back behind an earlier read, whichever node answers. With log_head, the node first waits until its fold has applied every record the surface’s log held when the read arrived. A client asks for it after its managed requests moved to another node, when a write whose reply was lost may sit on the log. A node that does not get there within its wait bound answers Stale, never older state.

Fields

v: u32

read: Vec<u8>

The read request the client would otherwise send on its own.

min_position: Option<MutationPosition>

log_head: bool

min_sessions: Vec<SessionPosition>

For a session read: the session fold must have applied each of these positions that still names a live, registered source partition of the read’s stream. Positions of other streams are ignored.

Trait Implementations

impl Clone for ManagedReadEnvelope

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ManagedReadEnvelope

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ManagedReadEnvelope

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ManagedReadEnvelope

impl PartialEq for ManagedReadEnvelope

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ManagedReadEnvelope

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ManagedReadEnvelope