Struct InvokeOutputCounters 

pub struct InvokeOutputCounters {
    pub produced_events: u64,
    pub produced_payload_bytes: u64,
    pub consumed_events: u64,
    pub consumed_payload_bytes: u64,
    pub retained_events: u64,
    pub retained_payload_bytes: u64,
    pub truncated_events: u64,
    pub truncated_payload_bytes: u64,
    pub dropped_events: u64,
    pub dropped_payload_bytes: u64,
    pub dropped_error_events: u64,
    pub saw_done: bool,
}

Exact invocation-local accounting. See module docs for identities.

Fields

produced_events: u64

Events/payload bytes the producer side handed to the sink (counted BEFORE the send, so a closed channel still counts).

produced_payload_bytes: u64

consumed_events: u64

Events/payload bytes the collector received from the channel.

consumed_payload_bytes: u64

retained_events: u64

Events/payload bytes retained for post-invoke consumption (truncated events count here with their KEPT byte length).

retained_payload_bytes: u64

truncated_events: u64

Events partially truncated to fit the byte budget, and the exact bytes trimmed from them.

truncated_payload_bytes: u64

dropped_events: u64

Events dropped whole, and their exact payload bytes.

dropped_payload_bytes: u64

dropped_error_events: u64

Subset of dropped_events that were CommandOutputEvent::Error — surfaced so error visibility survives the drop policy.

saw_done: bool

Whether the producer emitted a CommandOutputEvent::Done terminal marker.

Trait Implementations

impl Clone for InvokeOutputCounters

fn clone(&self) -> InvokeOutputCounters

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for InvokeOutputCounters

impl Debug for InvokeOutputCounters

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

Formats the value using the given formatter.

impl Default for InvokeOutputCounters

fn default() -> InvokeOutputCounters

Returns the “default value” for a type.

impl Eq for InvokeOutputCounters

impl PartialEq for InvokeOutputCounters

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for InvokeOutputCounters