Struct QueueMetrics

Source

pub struct QueueMetrics {
    pub at: DateTime<Utc>,
    pub queue: String,
    pub jobs_total: u64,
    pub jobs_completed: u64,
    pub jobs_failed: u64,
    pub jobs_retried: u64,
    pub jobs_dlq: u64,
    pub queue_depth: u64,
    pub execution_latency_ms_avg: f64,
    pub claim_latency_ms_avg: f64,
    pub retry_latency_ms_avg: f64,
    pub worker_count: u64,
}

Fields§

§at: DateTime<Utc>§queue: String§jobs_total: u64§jobs_completed: u64§jobs_failed: u64§jobs_retried: u64§jobs_dlq: u64§queue_depth: u64§execution_latency_ms_avg: f64§claim_latency_ms_avg: f64§retry_latency_ms_avg: f64§worker_count: u64

QueueMetrics

Struct QueueMetrics Copy item path

Fields§

Trait Implementations§

impl Clone for QueueMetrics

fn clone(&self) -> QueueMetrics

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

impl Debug for QueueMetrics

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

impl<'de> Deserialize<'de> for QueueMetrics

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

impl Serialize for QueueMetrics

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

Auto Trait Implementations§

impl Freeze for QueueMetrics

impl RefUnwindSafe for QueueMetrics

impl Send for QueueMetrics

impl Sync for QueueMetrics

impl Unpin for QueueMetrics

impl UnsafeUnpin for QueueMetrics

impl UnwindSafe for QueueMetrics

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> DeserializeOwned for Twhere T: for<'de> Deserialize<'de>,

impl<T> From<T> for T

fn from(t: T) -> T

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

fn into(self) -> U

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>

Struct QueueMetrics

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<T> CloneToUninit for T
where T: Clone,

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

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

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