Struct WorkerPolicyWindow 

pub struct WorkerPolicyWindow {

    pub sequence: u64,
    pub start_entry_ordinal: u64,
    pub end_entry_ordinal: u64,
    pub observed_entries: u64,
    pub observed_chunks: u64,
    pub observed_work_ns: u64,
    pub work_ns_per_entry: Option<u64>,
    pub work_ns_per_entry_unavailable_reason: Option<&'static str>,
    pub ready_directories: usize,
    pub in_flight_directories: usize,
    pub active_workers: usize,
    pub handoff_backlog: usize,
    pub requested_workers: Option<usize>,
    pub decision: WorkerPolicyDecision,
}

One controller evaluation over a half-open range of completed entry ordinals.

Fields

sequence: u64

Monotonic record number within this scan.

start_entry_ordinal: u64

First completed-entry ordinal represented by this window, inclusive.

end_entry_ordinal: u64

Ordinal immediately after the last represented entry.

observed_entries: u64

Entries contributing to the service-time signal.

observed_chunks: u64

Completed directory claims contributing to the service-time signal.

observed_work_ns: u64

Worker time contributing to the service-time signal.

work_ns_per_entry: Option<u64>

Derived service time, or null when no entry made the signal observable.

work_ns_per_entry_unavailable_reason: Option<&'static str>

Why work_ns_per_entry is null.

ready_directories: usize

Directories ready to claim when the controller evaluated the window.

in_flight_directories: usize

Claimed directories still being processed at that point.

active_workers: usize

Live worker threads at that point, including workers waiting for a claim.

handoff_backlog: usize

Observation batches sent but not yet received by the consumer.

requested_workers: Option<usize>

Worker target requested by a scale decision.

decision: WorkerPolicyDecision

What the controller concluded from this window.

Trait Implementations

impl Clone for WorkerPolicyWindow

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerPolicyWindow

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

Formats the value using the given formatter.

impl Eq for WorkerPolicyWindow

impl PartialEq for WorkerPolicyWindow

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for WorkerPolicyWindow