Struct PersistHealth 

pub struct PersistHealth {
    pub queued: Atomic<u64>,
    pub total_persisted: Atomic<u64>,
    pub total_errors: Atomic<u64>,
    pub consecutive_errors: Atomic<u64>,
    pub last_error: RwLock<Option<String>>,
    /* private fields */
}

Shared health state for a persister, readable from any thread.

Fields

queued: Atomic<u64>

Events queued but not yet written to the durable store.

total_persisted: Atomic<u64>

Lifetime count of successfully persisted events.

total_errors: Atomic<u64>

Lifetime count of failed persist attempts.

consecutive_errors: Atomic<u64>

Consecutive failures since last success (resets to 0 on success).

last_error: RwLock<Option<String>>

Most recent error message, if any.

Implementations

impl PersistHealth

pub fn record_enqueue(&self)

pub fn record_success(&self)

pub fn record_success_batch(&self, count: u64)

Record a batch of successful writes, decrementing queued by count.

pub fn record_error(&self, msg: String)

pub fn record_dropped(&self, msg: String)

pub fn record_error_no_dequeue(&self, msg: String)

Record an error without decrementing queued (event will be retried).

pub fn writes_per_second(&self) -> f64

Compute writes per second over a sliding window.

Each call checks whether the window has elapsed. If so, it rotates the window and returns the rate from the completed window. Otherwise it returns the instantaneous rate within the current window.

Trait Implementations

impl Debug for PersistHealth

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

Formats the value using the given formatter.

impl Default for PersistHealth

fn default() -> PersistHealth

Returns the “default value” for a type.