Struct StreamMetrics 

pub struct StreamMetrics { /* private fields */ }

Thread-safe aggregate metrics handle.

Construct one, pass an Arc<StreamMetrics> to Client::stream_arrow_with_observer, keep a clone, and call summary during or after the stream.

Implementations

impl StreamMetrics

pub fn new() -> Self

Create an empty metrics handle.

pub fn record_buffered_bytes(&self, bytes: u64)

Record the current undelivered-buffer size; keeps the observed maximum.

pub fn record_in_flight(&self, count: u64)

Record the current in-flight request count (one sample per scheduler iteration), for the mean-in-flight estimate.

pub fn record_elapsed(&self, elapsed: Duration)

Feed the engine’s monotonic elapsed time so throughput can be derived.

pub fn summary(&self) -> StreamSummary

Snapshot the current aggregate summary. Safe to call at any time.

Trait Implementations

impl Debug for StreamMetrics

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

Formats the value using the given formatter.

impl Default for StreamMetrics

fn default() -> Self

Returns the “default value” for a type.

impl StreamObserver for StreamMetrics

fn on_request(&self, stats: &RequestStats)

Called once for every completed HTTP request.

fn on_progress(&self, in_flight: u64, buffered_bytes: u64)

Called once per scheduler iteration with the current in-flight request count and undelivered reorder-buffer size. Lets observers track buffer high-water and concurrency saturation live. Default: no-op.

fn on_finish(&self, _summary: &StreamSummary)

Called once when the stream finishes (or is closed early), with the final aggregate summary. Default: no-op.