Struct LeanWorkerPoolSnapshot 

pub struct LeanWorkerPoolSnapshot {

    pub max_workers: usize,
    pub workers: usize,
    pub active_workers: usize,
    pub warm_leases: usize,
    pub queue_depth: usize,
    pub total_child_rss_kib: Option<u64>,
    pub rss_samples_unavailable: u64,
    pub requests: u64,
    pub imports: u64,
    pub worker_restarts: u64,
    pub max_request_restarts: u64,
    pub max_import_restarts: u64,
    pub rss_restarts: u64,
    pub idle_restarts: u64,
    pub cancelled_restarts: u64,
    pub timeout_restarts: u64,
    pub policy_restarts: u64,
    pub queue_timeouts: u64,
    pub memory_budget_rejections: u64,
    pub last_restart_reason: Option<LeanWorkerRestartReason>,
    pub stream_requests: u64,
    pub stream_successes: u64,
    pub stream_failures: u64,
    pub data_rows_delivered: u64,
    pub data_row_payload_bytes: u64,
    pub stream_elapsed: Duration,
    pub backpressure_waits: u64,
    pub backpressure_failures: u64,
}

Summary of public pool state.

This snapshot exposes admission and reuse facts without revealing worker ids, child pids, pipe handles, or which warm child will be selected.

Fields

max_workers: usize

workers: usize

active_workers: usize

warm_leases: usize

queue_depth: usize

total_child_rss_kib: Option<u64>

rss_samples_unavailable: u64

requests: u64

imports: u64

worker_restarts: u64

max_request_restarts: u64

max_import_restarts: u64

rss_restarts: u64

idle_restarts: u64

cancelled_restarts: u64

timeout_restarts: u64

policy_restarts: u64

queue_timeouts: u64

memory_budget_rejections: u64

last_restart_reason: Option<LeanWorkerRestartReason>

stream_requests: u64

stream_successes: u64

stream_failures: u64

data_rows_delivered: u64

data_row_payload_bytes: u64

stream_elapsed: Duration

backpressure_waits: u64

backpressure_failures: u64

Trait Implementations

impl Clone for LeanWorkerPoolSnapshot

fn clone(&self) -> LeanWorkerPoolSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LeanWorkerPoolSnapshot

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

Formats the value using the given formatter.

impl PartialEq for LeanWorkerPoolSnapshot

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

impl StructuralPartialEq for LeanWorkerPoolSnapshot