Struct TaskSchedulerQuotaHealthSnapshot

Source

pub struct TaskSchedulerQuotaHealthSnapshot {Show 15 fields
    pub identity: ExecutionIdentityV1,
    pub max_active: usize,
    pub observed: bool,
    pub live: bool,
    pub active: usize,
    pub pending: usize,
    pub blocked: bool,
    pub admitted: u64,
    pub released: u64,
    pub cancelled: u64,
    pub rejected: u64,
    pub peak_active: usize,
    pub total_wait_micros: u64,
    pub average_wait_micros: u64,
    pub max_wait_micros: u64,
}

Expand description

Bounded live-or-recent health for one scheduler quota identity.

Unlike TaskSchedulerQuotaSnapshot, this projection retains cumulative counters for a small bounded window after a quota becomes idle. It contains only the validated digest identity and numeric capacity data; scheduler labels, provider routing text, prompts, and payloads are never retained.

Fields§

§identity: ExecutionIdentityV1

Digest-only quota identity requested by the caller.

§max_active: usize

Immutable limit for this observed configuration epoch.

§observed: bool

Whether this scheduler has observed the requested identity/limit epoch.

§live: bool

Whether the quota currently has an active reservation or queued waiter.

§active: usize

Current active reservations for this identity.

§pending: usize

Current queued requests for this identity.

§blocked: bool

Whether pending work is currently blocked by this quota.

§admitted: u64

Successful admissions observed in the retained epoch.

§released: u64

Normally released reservations observed in the retained epoch.

§cancelled: u64

Queued or active admissions cancelled by their caller.

§rejected: u64

Pending admissions rejected while the scheduler was closing.

§peak_active: usize

Highest simultaneous reservation count observed for this identity.

§total_wait_micros: u64

Saturating sum of successful admission wait time in microseconds.

§average_wait_micros: u64

Mean successful admission wait time in microseconds.

§max_wait_micros: u64

Longest successful admission wait time in microseconds.

TaskSchedulerQuotaHealthSnapshot

Struct TaskSchedulerQuotaHealthSnapshot Copy item path

Fields§

Trait Implementations§

impl Clone for TaskSchedulerQuotaHealthSnapshot

fn clone(&self) -> TaskSchedulerQuotaHealthSnapshot

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

impl Debug for TaskSchedulerQuotaHealthSnapshot

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

impl<'de> Deserialize<'de> for TaskSchedulerQuotaHealthSnapshot

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl Eq for TaskSchedulerQuotaHealthSnapshot

impl PartialEq for TaskSchedulerQuotaHealthSnapshot

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

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

impl Serialize for TaskSchedulerQuotaHealthSnapshot

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

impl StructuralPartialEq for TaskSchedulerQuotaHealthSnapshot

Auto Trait Implementations§

impl Freeze for TaskSchedulerQuotaHealthSnapshot

impl RefUnwindSafe for TaskSchedulerQuotaHealthSnapshot

impl Send for TaskSchedulerQuotaHealthSnapshot

impl Sync for TaskSchedulerQuotaHealthSnapshot

impl Unpin for TaskSchedulerQuotaHealthSnapshot

impl UnsafeUnpin for TaskSchedulerQuotaHealthSnapshot

impl UnwindSafe for TaskSchedulerQuotaHealthSnapshot

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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for Twhere T: Clone,

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

impl<T> DeserializeOwned for Twhere T: for<'de> Deserialize<'de>,

impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ

fn with_current_context(self) -> WithContext<Self> ⓘ

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

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

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘwhere F: FnOnce(&Self) -> bool,

impl<T> ParallelSend for T

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

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

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

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 = !

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

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>

impl<T> WithSubscriber for T

Struct TaskSchedulerQuotaHealthSnapshot

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

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

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

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

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

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>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,