Skip to main content

SchedulerStats

Struct SchedulerStats

pub struct SchedulerStats {Show 17 fields
    pub enqueued: u64,
    pub dequeued: u64,
    pub expired: u64,
    pub dropped: u64,
    pub rejected_global: u64,
    pub rejected_tenant: u64,
    pub timeout_rejected: u64,
    pub dropped_policy: u64,
    pub queue_len_estimate: u64,
    pub max_global: u64,
    pub queue_saturation_ratio: f64,
    pub queue_time_sum_ns: u64,
    pub queue_time_samples: u64,
    pub queue_time_p95_ns: u64,
    pub queue_time_p99_ns: u64,
    pub queue_time_histogram: Vec<QueueTimeBucket>,
    pub top_tenants: Vec<TenantCount>,
}

Expand description

Snapshot of scheduler metrics.

Fields§

§enqueued: u64

Total accepted enqueues.

§dequeued: u64

Total successfully dequeued tasks.

§expired: u64

Total tasks dropped because deadlines expired before dispatch.

§dropped: u64

Total tasks dropped by reject/drop backpressure paths.

§rejected_global: u64

Total enqueue rejections due to global capacity.

§rejected_tenant: u64

Total enqueue rejections due to per-tenant capacity.

§timeout_rejected: u64

Total enqueue rejections caused by timeout.

§dropped_policy: u64

Total tasks dropped by replacement policies.

§queue_len_estimate: u64

Current estimated live queue length.

§max_global: u64

Configured global queue capacity.

§queue_saturation_ratio: f64

queue_len_estimate / max_global.

§queue_time_sum_ns: u64

Sum of queue time in nanoseconds for dequeued tasks.

§queue_time_samples: u64

Number of queue time samples.

§queue_time_p95_ns: u64

p95 queue time estimate in nanoseconds.

§queue_time_p99_ns: u64

p99 queue time estimate in nanoseconds.

§queue_time_histogram: Vec<QueueTimeBucket>

Histogram buckets for queue time.

§top_tenants: Vec<TenantCount>

Top talkers by recent observed volume.

Trait Implementations§

impl Clone for SchedulerStats

fn clone(&self) -> SchedulerStats

Returns a duplicate of the value. Read more

1.0.0 · Source§

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

Performs copy-assignment from source. Read more

impl Debug for SchedulerStats

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

Formats the value using the given formatter. Read more

impl Default for SchedulerStats

fn default() -> SchedulerStats

Returns the “default value” for a type. Read more

Auto Trait Implementations§

impl Freeze for SchedulerStats

impl RefUnwindSafe for SchedulerStats

impl Send for SchedulerStats

impl Sync for SchedulerStats

impl Unpin for SchedulerStats

impl UnwindSafe for SchedulerStats

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

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

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

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

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

fn into(self) -> U

Calls U::from(self).

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

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

type Owned = T

The resulting type after obtaining ownership.

fn to_owned(&self) -> T

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

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

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

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

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.