Struct LeanWorkerStats 

pub struct LeanWorkerStats {

    pub requests: u64,
    pub imports: u64,
    pub import_like_admission_attempts: u64,
    pub import_like_admitted: u64,
    pub last_import_like_rss_before_admission_kib: Option<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 replacement_attempts: u64,
    pub replacement_successes: u64,
    pub replacement_failures: u64,
    pub replacement_budget_admitted: u64,
    pub replacement_budget_skipped: u64,
    pub last_replacement_timing: Option<LeanWorkerReplacementTiming>,
    pub last_replacement_skipped_reason: Option<String>,
    pub last_spawn_handshake_elapsed: Option<Duration>,
    pub last_capability_load_elapsed: Option<Duration>,
    pub last_session_open_import_elapsed: Option<Duration>,
    pub last_first_command_elapsed: Option<Duration>,
    pub last_warm_command_elapsed: Option<Duration>,
    pub last_import_stats: Option<LeanWorkerImportStats>,
    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.

import_like_admission_attempts: u64

Import-like requests that reached the supervisor admission gate.

import_like_admitted: u64

Import-like requests admitted past parent-side restart/RSS policy.

last_import_like_rss_before_admission_kib: Option<u64>

Last sampled child RSS before an import-like request was admitted, when available.

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.

replacement_attempts: u64

Worker replacement attempts performed synchronously by this supervisor.

replacement_successes: u64

Successful worker replacements.

replacement_failures: u64

Failed worker replacements.

replacement_budget_admitted: u64

Replacements admitted by the configured policy without overlapping children.

replacement_budget_skipped: u64

Replacement attempts skipped by a budget guard.

last_replacement_timing: Option<LeanWorkerReplacementTiming>

Most recent replacement timing facts, if a replacement has succeeded.

last_replacement_skipped_reason: Option<String>

Most recent skipped replacement reason, if any.

last_spawn_handshake_elapsed: Option<Duration>

Most recent worker spawn and protocol-handshake elapsed time.

last_capability_load_elapsed: Option<Duration>

Most recent capability build/load phase elapsed time observed by a capability builder.

last_session_open_import_elapsed: Option<Duration>

Most recent host-session open/import elapsed time.

last_first_command_elapsed: Option<Duration>

Most recent first command elapsed time after opening or replacing a worker.

last_warm_command_elapsed: Option<Duration>

Most recent warm command elapsed time on an already-open worker.

last_import_stats: Option<LeanWorkerImportStats>

Lean-native import attribution for the most recent opened host session, 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 Eq for LeanWorkerStats

impl PartialEq for LeanWorkerStats

fn eq(&self, other: &LeanWorkerStats) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for LeanWorkerStats