Struct BitWheel 

pub struct BitWheel<T, const NUM_GEARS: usize = DEFAULT_GEARS, const RESOLUTION_MS: u64 = DEFAULT_RESOLUTION_MS, const SLOT_CAP: usize = DEFAULT_SLOT_CAP, const MAX_PROBES: usize = DEFAULT_MAX_PROBES> { /* private fields */ }

Implementations

impl<T, const NUM_GEARS: usize, const RESOLUTION_MS: u64, const SLOT_CAP: usize, const MAX_PROBES: usize> BitWheel<T, NUM_GEARS, RESOLUTION_MS, SLOT_CAP, MAX_PROBES>

pub fn with_epoch(epoch: Instant) -> Self

pub fn new() -> Self

pub fn boxed() -> Box<Self>

pub fn boxed_with_epoch(epoch: Instant) -> Box<Self>

pub const fn gear_granularities() -> [u64; NUM_GEARS]

Useful for deciding how to scale the BitWheel for your use case such that it satisfies the timer constraints.

pub const fn memory_footprint() -> usize

Useful for deciding how to scale the BitWheel for your use case such that it does not take up a tremendous amount of memory.

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

pub fn is_empty(&self) -> bool

pub fn insert( &mut self, when: Instant, timer: T, ) -> Result<TimerHandle, InsertError<T>>

pub fn cancel(&mut self, handle: TimerHandle) -> Option<T>

pub fn poll( &mut self, now: Instant, ctx: &mut T::Context, ) -> Result<usize, PollError>

where T: Timer,

Trait Implementations

impl<T, const NUM_GEARS: usize, const RESOLUTION_MS: u64, const SLOT_CAP: usize, const MAX_PROBES: usize> Default for BitWheel<T, NUM_GEARS, RESOLUTION_MS, SLOT_CAP, MAX_PROBES>

fn default() -> Self

Returns the “default value” for a type.

impl<T, const G: usize, const R: u64, const S: usize, const P: usize> TimerDriver<T> for BitWheel<T, G, R, S, P>

where T: Timer,

fn insert( &mut self, when: Instant, timer: T, ) -> Result<TimerHandle, InsertError<T>>

Insert a timer to fire at the given instant.

fn cancel(&mut self, handle: TimerHandle) -> Option<T>

Cancel a pending timer.

fn poll( &mut self, now: Instant, ctx: &mut T::Context, ) -> Result<usize, PollError>

Poll the wheel, firing all timers due by now.