Struct LeanWorkerStats 

pub struct LeanWorkerStats {

    pub requests: u64,
    pub imports: u64,
    pub exits: u64,
    pub restarts: u64,
    pub explicit_cycles: 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 rss_samples_unavailable: u64,
    pub last_rss_kib: Option<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,
}

Snapshot of worker lifecycle counters.

Fields

requests: u64

Requests that entered a worker child.

imports: u64

Import-like requests that entered a worker child.

exits: u64

Child exits observed by the supervisor, including policy cycles.

restarts: u64

Policy or explicit restarts performed by the supervisor.

explicit_cycles: u64

Explicit process cycles.

max_request_restarts: u64

Restarts caused by LeanWorkerRestartPolicy::max_requests.

max_import_restarts: u64

Restarts caused by LeanWorkerRestartPolicy::max_imports.

rss_restarts: u64

Restarts caused by LeanWorkerRestartPolicy::max_rss_kib.

idle_restarts: u64

Restarts caused by LeanWorkerRestartPolicy::idle_restart_after.

cancelled_restarts: u64

Restarts caused by parent-side cancellation of an in-flight request.

timeout_restarts: u64

Restarts caused by parent-side request timeouts.

rss_samples_unavailable: u64

RSS checks skipped because the platform did not provide a usable sample.

last_rss_kib: Option<u64>

Last measured child RSS in KiB, when a policy check could sample it.

last_restart_reason: Option<LeanWorkerRestartReason>

Most recent restart reason, if any.

stream_requests: u64

Streaming requests that entered a worker child.

stream_successes: u64

Streaming requests that reached terminal success.

stream_failures: u64

Streaming requests that failed after entering the child.

data_rows_delivered: u64

Data rows delivered to parent-side sinks.

data_row_payload_bytes: u64

Raw row payload bytes delivered to parent-side sinks.

stream_elapsed: Duration

Total elapsed time spent in streaming requests.

backpressure_waits: u64

Times the bounded worker-event reader had to wait for the parent to drain events.

backpressure_failures: u64

Streaming requests that failed after bounded-buffer backpressure was observed.

Trait Implementations

impl Clone for LeanWorkerStats

fn clone(&self) -> LeanWorkerStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LeanWorkerStats

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

Formats the value using the given formatter.

impl Default for LeanWorkerStats

fn default() -> LeanWorkerStats

Returns the “default value” for a type.

impl PartialEq for LeanWorkerStats

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

impl StructuralPartialEq for LeanWorkerStats