Struct OrderingSnapshot 

pub struct OrderingSnapshot {
    pub enabled: bool,
    pub sessions: Vec<OrderingSessionSnapshot>,
    pub skipped_session_count: usize,
}

Diagnostic projection of receiver-local ordering state.

Each OrderingSessionSnapshot corresponds to one sender session keyed by SeqInfo::Session.session_id. Sequence progress here means “released into the actor work queue”, not “processed by the actor handler”.

Carries completeness metadata so callers can distinguish “no stalled sessions” from “snapshot was partial” from “buffering is disabled”.

Fields

enabled: bool

Whether reorder buffering is enabled. When false, messages bypass sequencing, and sessions is empty even under load.

sessions: Vec<OrderingSessionSnapshot>

Per-session entries, sorted by session_id for stable output. Includes idle (drained) sessions with buffered_count == 0.

skipped_session_count: usize

Sessions that could not be observed because sequencing state was busy when we tried to snapshot. NOT in sessions. Zero means the snapshot is complete.

Implementations

impl OrderingSnapshot

pub fn is_complete(&self) -> bool

True when no session was skipped, i.e., every live session’s state was successfully captured in sessions.

Trait Implementations

impl AttrValue for OrderingSnapshot

fn display(&self) -> String

Display the value, typically using std::fmt::Display. This is called to show the output in human-readable form.

fn parse(value: &str) -> Result<Self, Error>

Parse a value from a string, typically using std::str::FromStr.

impl Clone for OrderingSnapshot

fn clone(&self) -> OrderingSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OrderingSnapshot

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OrderingSnapshot

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for OrderingSnapshot

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

Formats the value using the given formatter.

impl FromStr for OrderingSnapshot

type Err = Error

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self, Self::Err>

Parses a string s to return a value of this type.

impl Named for OrderingSnapshot

fn typename() -> &'static str

The globally unique type name for the type. This should typically be the fully qualified Rust name of the type.

fn typehash() -> u64

A globally unique hash for this type. TODO: actually enforce perfect hashing

fn typeid() -> TypeId

The TypeId for this type. TypeIds are unique only within a binary, and should not be used for global identification.

fn port() -> u64

A globally unique numeric identifier for this type.

fn arm(&self) -> Option<&'static str>

If the named type is an enum, this returns the name of the arm of the value self.

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

An unsafe version of ‘arm’, accepting a pointer to the value, for use in type-erased settings.

impl PartialEq for OrderingSnapshot

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for OrderingSnapshot

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 OrderingSnapshot