Struct DerivedStateConsumerTelemetry 

pub struct DerivedStateConsumerTelemetry {
    pub name: &'static str,
    pub unhealthy: bool,
    pub recovery_state: DerivedStateConsumerRecoveryState,
    pub applied_events: u64,
    pub checkpoint_flushes: u64,
    pub fault_count: u64,
    pub last_applied_sequence: Option<FeedSequence>,
    pub last_fault_sequence: Option<FeedSequence>,
    pub last_fault_kind: Option<DerivedStateConsumerFaultKind>,
}

Snapshot of one registered derived-state consumer’s live-feed health and counters.

Fields

name: &'static str

Stable consumer name used in logs and telemetry.

unhealthy: bool

Whether live continuity has been lost for this consumer.

recovery_state: DerivedStateConsumerRecoveryState

Recovery state for the consumer.

applied_events: u64

Total number of successfully applied envelopes.

checkpoint_flushes: u64

Total number of successfully flushed checkpoints.

fault_count: u64

Total number of structured faults recorded for the consumer.

last_applied_sequence: Option<FeedSequence>

Highest applied sequence when known.

last_fault_sequence: Option<FeedSequence>

Highest fault-associated sequence when known.

last_fault_kind: Option<DerivedStateConsumerFaultKind>

Last structured fault kind when known.

Trait Implementations

impl Clone for DerivedStateConsumerTelemetry

fn clone(&self) -> DerivedStateConsumerTelemetry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DerivedStateConsumerTelemetry

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

Formats the value using the given formatter.

impl PartialEq for DerivedStateConsumerTelemetry

fn eq(&self, other: &DerivedStateConsumerTelemetry) -> 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 Eq for DerivedStateConsumerTelemetry

impl StructuralPartialEq for DerivedStateConsumerTelemetry