Struct TimerRegistry 

pub struct TimerRegistry { /* private fields */ }

A registry for tracking timers by identifier.

Implementations

impl TimerRegistry

pub fn new() -> Self

Creates a new timer registry.

pub async fn insert(&self, timer: Timer) -> u64

Inserts an existing timer and returns its identifier.

pub async fn start_once<F>( &self, delay: Duration, callback: F, ) -> Result<(u64, Timer), TimerError>

where F: TimerCallback + 'static,

Starts and registers a one-time timer.

pub async fn start_at<F>( &self, deadline: Instant, callback: F, ) -> Result<(u64, Timer), TimerError>

where F: TimerCallback + 'static,

Starts and registers a one-time timer at a deadline.

pub async fn start_recurring<F>( &self, schedule: RecurringSchedule, callback: F, ) -> Result<(u64, Timer), TimerError>

where F: TimerCallback + 'static,

Starts and registers a recurring timer.

pub async fn remove(&self, id: u64) -> Option<Timer>

Removes a timer from the registry and returns it.

pub async fn contains(&self, id: u64) -> bool

Returns true when the registry tracks the given timer identifier.

pub async fn stop(&self, id: u64) -> Result<Option<TimerOutcome>, TimerError>

Stops a timer by identifier when it exists.

pub async fn cancel(&self, id: u64) -> Result<Option<TimerOutcome>, TimerError>

Cancels a timer by identifier when it exists.

pub async fn pause(&self, id: u64) -> Result<bool, TimerError>

Pauses a timer by identifier when it exists.

pub async fn resume(&self, id: u64) -> Result<bool, TimerError>

Resumes a timer by identifier when it exists.

pub async fn stop_all(&self)

Stops all timers currently tracked by the registry.

pub async fn pause_all(&self)

Pauses all running timers currently tracked by the registry.

pub async fn join_all(&self) -> Vec<(u64, TimerOutcome)>

Waits for all tracked timers that have a joinable outcome.

pub async fn cancel_all(&self)

Cancels all timers currently tracked by the registry.

pub async fn resume_all(&self)

Resumes all paused timers currently tracked by the registry.

pub async fn active_ids(&self) -> Vec<u64>

Lists all active timers.

pub async fn get(&self, id: u64) -> Option<Timer>

Retrieves a timer by ID.

pub async fn snapshot(&self, id: u64) -> Option<RegisteredTimer>

Returns a snapshot of a tracked timer by identifier.

pub async fn list(&self) -> Vec<RegisteredTimer>

Lists snapshots for all tracked timers.

pub async fn find_by_label(&self, label: &str) -> Vec<u64>

Returns the identifiers for timers carrying a matching label.

pub async fn len(&self) -> usize

Returns the number of tracked timers.

pub async fn is_empty(&self) -> bool

Returns true when the registry is empty.

pub async fn clear(&self) -> usize

Removes all tracked timers and returns the number removed.

Trait Implementations

impl Clone for TimerRegistry

fn clone(&self) -> TimerRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for TimerRegistry

fn default() -> TimerRegistry

Returns the “default value” for a type.