Struct QueryMetrics 

pub struct QueryMetrics {
    pub ring0_events_in: u64,
    pub ring0_events_out: u64,
    pub ring0_events_dropped: u64,
    pub ring0_total_ns: u64,
    pub bridge_pending: u64,
    pub bridge_backpressure_drops: u64,
    pub bridge_batches_flushed: u64,
    pub ring1_rows_flushed: u64,
    pub pipelines_compiled: u64,
    pub pipelines_fallback: u64,
}

Aggregated runtime metrics for a streaming query.

Fields

ring0_events_in: u64

Total events submitted to Ring 0.

ring0_events_out: u64

Events emitted from Ring 0 to bridges.

ring0_events_dropped: u64

Events dropped by Ring 0 pipelines (filtered out).

ring0_total_ns: u64

Cumulative Ring 0 processing time in nanoseconds.

bridge_pending: u64

Events pending in bridge queues.

bridge_backpressure_drops: u64

Events dropped due to bridge backpressure.

bridge_batches_flushed: u64

Total batches flushed to Ring 1.

ring1_rows_flushed: u64

Total rows flushed to Ring 1 across all batches.

pipelines_compiled: u64

Number of compiled (JIT) pipelines.

pipelines_fallback: u64

Number of fallback (interpreted) pipelines.

Trait Implementations

impl Clone for QueryMetrics

fn clone(&self) -> QueryMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueryMetrics

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

Formats the value using the given formatter.

impl Default for QueryMetrics

fn default() -> QueryMetrics

Returns the “default value” for a type.

impl PartialEq for QueryMetrics

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

impl StructuralPartialEq for QueryMetrics