Struct HashedWheelTimer 

pub struct HashedWheelTimer<T> { /* private fields */ }

Single-level hashed wheel timer indexed by event ID.

This timer is deterministic:

• Events are grouped by (tick, delta_tick) waves.
• Events in the same wave are popped in ascending event_id.

on_tick passed to schedule is clamped to curr_tick, so scheduling into the past places the event on the current tick.

Implementations

impl<T> HashedWheelTimer<T>

pub fn new(buckets_num: usize) -> Self

Creates a timer with a fixed number of buckets.

buckets_num must be greater than 0.

pub fn count_all(&self) -> usize

Returns the total number of scheduled events.

pub fn count_in_bucket( &self, bucket_index: usize, ) -> Result<usize, TimeWheelError>

Returns number of events currently stored in a bucket.

This is a bucket-level view, not limited to curr_tick.

pub fn is_empty(&self) -> bool

Returns true when no events are scheduled.

pub fn is_empty_bucket( &self, bucket_index: usize, ) -> Result<bool, TimeWheelError>

Returns true when a bucket contains no events.

pub fn has_events_in_current_tick(&self) -> bool

Returns true if the current tick still has at least one wave to pop.

pub fn curr_tick(&self) -> u64

Returns current absolute tick.

pub fn curr_bucket(&self) -> usize

Returns current bucket index.

pub fn curr_delta_tick(&self) -> u64

Returns current wave (delta_tick) inside curr_tick.

pub fn curr_seq_id(&self) -> EventId

Returns the latest assigned sequence ID.

pub fn schedule(&mut self, on_tick: u64, data: T) -> ScheduleResult

Schedules a new event and returns its ID.

If on_tick < curr_tick, the event is scheduled on curr_tick.

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

Returns true if an event with id exists.

pub fn get(&self, id: EventId) -> Option<&Event<T>>

Returns event by ID.

pub fn remove(&mut self, id: EventId) -> Option<Event<T>>

Removes and returns an event by ID.

pub fn update( &mut self, id: EventId, on_tick: u64, data: T, ) -> Option<UpdateResult>

Replaces event payload and scheduled tick by ID.

pub fn reschedule(&mut self, id: EventId, on_tick: u64) -> Option<UpdateResult>

Moves existing event to another tick preserving payload.

pub fn pop_events(&mut self) -> Vec<Event<T>>

Pops a single wave of events for current tick.

Returns empty vector when current tick has no remaining events.

pub fn step(&mut self)

Advances timer by one tick and moves to next bucket.

pub fn reset(&mut self)

Clears all events and resets timer state.

Trait Implementations

impl<T: Debug> Debug for HashedWheelTimer<T>

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

Formats the value using the given formatter.