Skip to main content

WorkerPolicyDiagnostics

Struct WorkerPolicyDiagnostics 

Source
pub struct WorkerPolicyDiagnostics {
Show 20 fields pub controller: &'static str, pub available_parallelism: usize, pub initial_workers: usize, pub maximum_workers: usize, pub calibration_window_entries: Option<u64>, pub slow_threshold_ns_per_entry: Option<u64>, pub calibration_chunks: u64, pub calibration_entries: u64, pub calibration_work_ns: u64, pub worker_expansions: u64, pub outcome: WorkerPolicyOutcome, pub outcome_reason: Option<&'static str>, pub workers_spawned: usize, pub peak_active_workers: usize, pub ready_directories_at_finish: usize, pub in_flight_directories_at_finish: usize, pub handoff_backlog_at_finish: usize, pub handoff_backlog_high_water: usize, pub windows: Vec<WorkerPolicyWindow>, pub events_truncated: bool,
}
Expand description

Worker-controller configuration, trace, and terminal queue state.

Fields§

§controller: &'static str

Controller variant exercised by this scan.

§available_parallelism: usize

Parallelism reported by the operating system when the scan began.

§initial_workers: usize

Workers in the pool before any adaptive decision.

§maximum_workers: usize

Hard maximum workers this scan could activate.

§calibration_window_entries: Option<u64>

Entry target for an adaptive window, or null for a fixed pool.

§slow_threshold_ns_per_entry: Option<u64>

Slow-service trigger, or null for a fixed pool.

§calibration_chunks: u64

Directory chunks folded into live controller windows.

§calibration_entries: u64

Entries folded into live controller windows.

§calibration_work_ns: u64

Worker time folded into live controller windows.

§worker_expansions: u64

Expansion messages that caused the consumer to create more workers.

§outcome: WorkerPolicyOutcome

Terminal policy outcome.

§outcome_reason: Option<&'static str>

Explanation when no adaptive evaluation exists.

§workers_spawned: usize

Total worker threads created during the walk.

§peak_active_workers: usize

Maximum simultaneously live worker threads, including workers waiting for work.

§ready_directories_at_finish: usize

Ready directories at scan completion; a complete walk must leave zero.

§in_flight_directories_at_finish: usize

In-flight directories at scan completion; a complete walk must leave zero.

§handoff_backlog_at_finish: usize

Observation batches outstanding at scan completion.

§handoff_backlog_high_water: usize

Maximum outstanding observation batches during the scan.

§windows: Vec<WorkerPolicyWindow>

Bounded controller history.

§events_truncated: bool

True when controller history exceeded the 256-event diagnostic bound.

Trait Implementations§

Source§

impl Clone for WorkerPolicyDiagnostics

Source§

fn clone(&self) -> Self

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for WorkerPolicyDiagnostics

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Eq for WorkerPolicyDiagnostics

Source§

impl PartialEq for WorkerPolicyDiagnostics

Source§

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

Equality operator ==. Read more
1.0.0 (const: unstable) · Source§

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

Inequality operator !=. Read more
Source§

impl StructuralPartialEq for WorkerPolicyDiagnostics

Auto Trait Implementations§

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

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

Source§

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

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

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

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

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

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

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

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

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

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.