Struct ReceiptWriterCounters 

pub struct ReceiptWriterCounters {
    pub accepted_total: u64,
    pub committed_total: u64,
    pub failed_total: u64,
    pub saturated_total: u64,
    pub inflight: u64,
    pub timed_out_total: u64,
    pub timed_out_inflight: u64,
    pub queue_depth: u64,
    pub last_commit_unix_ms: Option<u64>,
    pub first_accept_unix_ms: Option<u64>,
    pub last_error: Option<String>,
}

Fields

accepted_total: u64

committed_total: u64

failed_total: u64

saturated_total: u64

inflight: u64

timed_out_total: u64

Caller-visible writer deadlines exceeded. This is separate from failed_total, which counts only the actor’s terminal failed outcomes.

timed_out_inflight: u64

Timed-out commands that are still queued or running on the actor.

queue_depth: u64

Commands still queued in the commit-actor channel, not yet pulled for processing. Unlike inflight, this excludes work the actor has already drained and is committing, so it is the honest saturation signal: the channel is full only once this reaches its capacity.

last_commit_unix_ms: Option<u64>

first_accept_unix_ms: Option<u64>

Wall-clock (unix-ms) of the first append this writer ever accepted, set once. It anchors the stall clock before the first successful commit, so a writer that wedges before ever committing is still measured against the stall threshold instead of appearing to make progress forever.

last_error: Option<String>

Trait Implementations

impl Clone for ReceiptWriterCounters

fn clone(&self) -> ReceiptWriterCounters

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReceiptWriterCounters

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

Formats the value using the given formatter.

impl Default for ReceiptWriterCounters

fn default() -> ReceiptWriterCounters

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ReceiptWriterCounters

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ReceiptWriterCounters

impl PartialEq for ReceiptWriterCounters

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ReceiptWriterCounters

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 ReceiptWriterCounters