Struct WriterMetricsSnapshot 

pub struct WriterMetricsSnapshot {
    pub outstanding_batches: u64,
    pub batches_received: u64,
    pub rows_received: u64,
    pub batches_sent: u64,
    pub rows_sent: u64,
    pub errors: u64,
    pub batches_failed: u64,
    pub rows_failed: u64,
    pub batches_spilled: u64,
    pub rows_spilled: u64,
    pub max_outstanding_batches: u64,
}

Live snapshot of background-writer metrics.

Fields

outstanding_batches: u64

Number of batches currently submitted to the writer but not yet dequeued.

batches_received: u64

Number of batches accepted by the background writer loop.

rows_received: u64

Total number of rows accepted by the background writer loop.

batches_sent: u64

Number of batches successfully sent.

rows_sent: u64

Total number of rows across all successful batches.

errors: u64

Total number of failed send attempts (including retries).

batches_failed: u64

Number of batches dropped after all retries were exhausted.

rows_failed: u64

Total number of rows dropped after all retries were exhausted.

batches_spilled: u64

Number of batches written to the spill directory.

rows_spilled: u64

Total number of rows written to the spill directory.

max_outstanding_batches: u64

Maximum observed outstanding-batch count submitted to the writer.

Trait Implementations

impl Clone for WriterMetricsSnapshot

fn clone(&self) -> WriterMetricsSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WriterMetricsSnapshot

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

Formats the value using the given formatter.

impl Default for WriterMetricsSnapshot

fn default() -> WriterMetricsSnapshot

Returns the “default value” for a type.

impl PartialEq for WriterMetricsSnapshot

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

impl Eq for WriterMetricsSnapshot

impl StructuralPartialEq for WriterMetricsSnapshot