Struct PoolMetrics

Source

pub struct PoolMetrics {Show 20 fields
    pub total_proxies: usize,
    pub healthy_proxies: usize,
    pub cooldown_proxies: usize,
    pub dead_proxies: usize,
    pub pending_tasks: usize,
    pub delayed_tasks: usize,
    pub completed_tasks: u64,
    pub failed_tasks: u64,
    pub throughput_1s: f64,
    pub throughput_10s: f64,
    pub throughput_60s: f64,
    pub success_rate_1m: f64,
    pub avg_latency_ms: f64,
    pub inflight: usize,
    pub requeued_tasks: u64,
    pub zero_available_events: u64,
    pub skipped_no_permit: u64,
    pub skipped_rate_limit: u64,
    pub skipped_cooldown: u64,
    pub dispatch_count: u64,
}

Expand description

Snapshot of the overall proxy-pool and task-pool state.

Returned by ScatterProxy::metrics() so callers can build dashboards, alerting, or adaptive back-pressure on top of the scheduler.

Fields§

§total_proxies: usize§healthy_proxies: usize§cooldown_proxies: usize§dead_proxies: usize§pending_tasks: usize§delayed_tasks: usize§completed_tasks: u64§failed_tasks: u64§throughput_1s: f64§throughput_10s: f64§throughput_60s: f64§success_rate_1m: f64§avg_latency_ms: f64§inflight: usize§requeued_tasks: u64§zero_available_events: u64§skipped_no_permit: u64§skipped_rate_limit: u64§skipped_cooldown: u64§dispatch_count: u64

PoolMetrics

Struct PoolMetrics Copy item path

Fields§

Trait Implementations§

impl Clone for PoolMetrics

fn clone(&self) -> PoolMetrics

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

impl Debug for PoolMetrics

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

impl Default for PoolMetrics

fn default() -> PoolMetrics

Auto Trait Implementations§

impl Freeze for PoolMetrics

impl RefUnwindSafe for PoolMetrics

impl Send for PoolMetrics

impl Sync for PoolMetrics

impl Unpin for PoolMetrics

impl UnsafeUnpin for PoolMetrics

impl UnwindSafe for PoolMetrics

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> 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> PolicyExt for Twhere T: ?Sized,

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

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

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>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct PoolMetrics

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> PolicyExt for T
where T: ?Sized,

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

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

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

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

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