Struct TaskQueueStats 

pub struct TaskQueueStats {
    pub total_submitted: u64,
    pub completed: u64,
    pub failed: u64,
    pub in_flight: u64,
    pub total_latency_nanos: u128,
    pub completed_latency_samples: u64,
}

Snapshot of task queue statistics for observability.

Obtained via TaskQueue::stats.

Fields

total_submitted: u64

Total number of tasks submitted to the queue.

completed: u64

Number of tasks that completed successfully.

failed: u64

Number of tasks that failed (panicked).

in_flight: u64

Number of tasks currently being executed by workers.

total_latency_nanos: u128

Sum of end-to-end latencies (enqueue -> completion) in nanoseconds for every task that has finished (successfully or with a panic).

completed_latency_samples: u64

Number of completed tasks that have contributed to total_latency_nanos.

Implementations

impl TaskQueueStats

pub fn average_latency(&self) -> Option<Duration>

Return the average end-to-end task latency (enqueue -> completion).

Returns None when no tasks have completed yet.

Example

use philiprehberger_task_queue::TaskQueue;

let queue = TaskQueue::new(1);
queue.submit(|| 1 + 1).join().unwrap();
let stats = queue.stats();
assert!(stats.average_latency().is_some());
queue.shutdown();

Trait Implementations

impl Clone for TaskQueueStats

fn clone(&self) -> TaskQueueStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskQueueStats

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

Formats the value using the given formatter.