Struct LeanWorkerPoolSnapshot

Source

pub struct LeanWorkerPoolSnapshot {Show 56 fields
    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 cold_open_attempts: u64,
    pub cold_open_admitted: u64,
    pub cold_open_refusals: u64,
    pub key_hits: u64,
    pub key_misses: u64,
    pub distinct_keys_seen: u64,
    pub fresh_cold_opens_avoided: u64,
    pub miss_empty_pool: u64,
    pub miss_no_matching_key: u64,
    pub last_key_miss_reason: Option<String>,
    pub import_like_requests: u64,
    pub concurrent_cold_opens_observed: u64,
    pub rss_before_admission_kib: Option<u64>,
    pub rss_after_open_kib: Option<u64>,
    pub refusal_reason: Option<String>,
    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_restart_reason: Option<LeanWorkerRestartReason>,
    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,
}

Expand description

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§cold_open_attempts: u64§cold_open_admitted: u64§cold_open_refusals: u64§key_hits: u64§key_misses: u64§distinct_keys_seen: u64§fresh_cold_opens_avoided: u64§miss_empty_pool: u64§miss_no_matching_key: u64§last_key_miss_reason: Option<String>§import_like_requests: u64§concurrent_cold_opens_observed: u64§rss_before_admission_kib: Option<u64>§rss_after_open_kib: Option<u64>§refusal_reason: Option<String>§replacement_attempts: u64§replacement_successes: u64§replacement_failures: u64§replacement_budget_admitted: u64§replacement_budget_skipped: u64§last_replacement_timing: Option<LeanWorkerReplacementTiming>§last_replacement_skipped_reason: Option<String>§last_spawn_handshake_elapsed: Option<Duration>§last_capability_load_elapsed: Option<Duration>§last_session_open_import_elapsed: Option<Duration>§last_first_command_elapsed: Option<Duration>§last_warm_command_elapsed: Option<Duration>§last_restart_reason: Option<LeanWorkerRestartReason>§last_import_stats: Option<LeanWorkerImportStats>§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

LeanWorkerPoolSnapshot

Struct LeanWorkerPoolSnapshot Copy item path

Fields§

Trait Implementations§

impl Clone for LeanWorkerPoolSnapshot

fn clone(&self) -> LeanWorkerPoolSnapshot

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

impl Debug for LeanWorkerPoolSnapshot

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

impl Eq for LeanWorkerPoolSnapshot

impl PartialEq for LeanWorkerPoolSnapshot

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

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

impl StructuralPartialEq for LeanWorkerPoolSnapshot

Auto Trait Implementations§

impl Freeze for LeanWorkerPoolSnapshot

impl RefUnwindSafe for LeanWorkerPoolSnapshot

impl Send for LeanWorkerPoolSnapshot

impl Sync for LeanWorkerPoolSnapshot

impl Unpin for LeanWorkerPoolSnapshot

impl UnsafeUnpin for LeanWorkerPoolSnapshot

impl UnwindSafe for LeanWorkerPoolSnapshot

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Struct LeanWorkerPoolSnapshot

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,