Struct MetricsBatch

pub(crate) struct MetricsBatch {
    busy_duration_total: u64,
    processing_scheduled_tasks_started_at: Option<Instant>,
    park_count: u64,
    park_unpark_count: u64,
}

Fields

busy_duration_total: u64

The total busy duration in nanoseconds.

processing_scheduled_tasks_started_at: Option<Instant>

Instant at which work last resumed (continued after park).

park_count: u64

Number of times the worker parked.

park_unpark_count: u64

Number of times the worker parked and unparked.

Implementations

impl MetricsBatch

pub(crate) fn new(worker_metrics: &WorkerMetrics) -> MetricsBatch

fn new_unstable( _worker_metrics: &WorkerMetrics, maybe_now: Option<Instant>, ) -> MetricsBatch

pub(crate) fn submit(&mut self, worker: &WorkerMetrics, mean_poll_time: u64)

fn submit_unstable(&mut self, worker: &WorkerMetrics, _mean_poll_time: u64)

pub(crate) fn about_to_park(&mut self)

The worker is about to park.

pub(crate) fn unparked(&mut self)

The worker was unparked.

pub(crate) fn start_processing_scheduled_tasks(&mut self)

Start processing a batch of tasks

pub(crate) fn end_processing_scheduled_tasks(&mut self)

Stop processing a batch of tasks

pub(crate) fn start_poll(&mut self)

Start polling an individual task

pub(crate) fn end_poll(&mut self)

Stop polling an individual task

pub(crate) fn inc_local_schedule_count(&mut self)

impl MetricsBatch

pub(crate) fn incr_steal_count(&mut self, _by: u16)

pub(crate) fn incr_steal_operations(&mut self)

pub(crate) fn incr_overflow_count(&mut self)