Struct TaskScheduler 

pub struct TaskScheduler { /* private fields */ }

Implementations

impl TaskScheduler

pub fn new(broker: Arc<RedisBroker>) -> Self

pub fn with_tick_interval( broker: Arc<RedisBroker>, interval_seconds: u64, ) -> Self

pub fn start(broker: Arc<RedisBroker>) -> Result<JoinHandle<()>, TaskQueueError>

pub async fn schedule_task<T: Task>( &self, task: T, queue: &str, delay: Duration, ) -> Result<TaskId, TaskQueueError>

pub async fn process_scheduled_tasks( broker: &RedisBroker, ) -> Result<(), TaskQueueError>