Struct TimerScheduler 

pub struct TimerScheduler { /* private fields */ }

Timer-based scheduler for real-time mode.

Respects actual timestamps using tokio timers. Functions are scheduled to execute at their specified timestamps, with earlier timestamps executing first.

Implementations

impl TimerScheduler

pub fn new() -> Self

Create a new timer scheduler.

pub async fn pending_count(&self) -> usize

Get the number of pending tasks.

Trait Implementations

impl Default for TimerScheduler

fn default() -> Self

Returns the “default value” for a type.

impl Scheduler for TimerScheduler

fn schedule_function( &mut self, start_invocation: BoxedAsyncFn, on_error: ErrorHandler, timestamp: Option<DateTime<Utc>>, update_checkpoint: Option<CheckpointUpdateFn>, )

Schedule a function to be executed.

fn has_scheduled_function(&self) -> bool

Check if there are scheduled functions pending.

fn flush_timers(&mut self)

Flush all scheduled functions without executing them.

fn process_next(&mut self) -> Pin<Box<dyn Future<Output = bool> + Send + '_>>

Process the next scheduled function (if any).