Struct TemporalScheduler 

pub struct TemporalScheduler { /* private fields */ }

Advanced temporal scheduler.

Implementations

impl TemporalScheduler

pub fn new() -> Self

pub fn schedule( &mut self, channel_id: u64, sender: &str, content: &str, target: TemporalTarget, ) -> u64

Schedule a message for temporal delivery.

pub fn register_condition<F>(&mut self, name: &str, evaluator: F)

where F: Fn(&str) -> bool + Send + Sync + 'static,

Register a condition evaluator.

pub fn check_ready(&mut self) -> DeliveryCheck

Check which messages are ready for delivery.

pub fn mark_delivered(&mut self, id: u64) -> bool

Mark a message as delivered.

pub fn cancel(&mut self, id: u64) -> bool

Cancel a pending message.

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

Get a pending message by ID.

pub fn list_by_status(&self, status: &PendingStatus) -> Vec<&PendingMessage>

List all pending messages by status.

pub fn stats(&self) -> (usize, usize, usize, usize)

Get total message counts: (waiting, delivered, cancelled, failed).

pub fn expire_old(&mut self, max_age_secs: u64) -> usize

Expire messages older than max_age_secs.

pub fn total_count(&self) -> usize

Get count of all messages.

Trait Implementations

impl Debug for TemporalScheduler

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

Formats the value using the given formatter.

impl Default for TemporalScheduler

fn default() -> Self

Returns the “default value” for a type.