Trait TaskScheduler 

pub trait TaskScheduler:
    Send
    + Sync
    + Debug {
    // Required methods
    fn schedule_task(&mut self, task: ExecutionTask) -> SklResult<String>;
    fn schedule_batch(
        &mut self,
        tasks: Vec<ExecutionTask>,
    ) -> SklResult<Vec<String>>;
    fn next_task(&mut self) -> Option<ExecutionTask>;
    fn cancel_task(&mut self, task_id: &str) -> SklResult<()>;
    fn queue_status(&self) -> QueueStatus;
    fn start(&mut self) -> SklResult<()>;
    fn pause(&mut self) -> SklResult<()>;
    fn resume(&mut self) -> SklResult<()>;
    fn shutdown(&mut self) -> SklResult<()>;
    fn health_check(&self) -> Health;
}

Core task scheduler trait

Required Methods

fn schedule_task(&mut self, task: ExecutionTask) -> SklResult<String>

Schedule a task for execution

fn schedule_batch( &mut self, tasks: Vec<ExecutionTask>, ) -> SklResult<Vec<String>>

Schedule multiple tasks

fn next_task(&mut self) -> Option<ExecutionTask>

Get next task to execute

fn cancel_task(&mut self, task_id: &str) -> SklResult<()>

Cancel a scheduled task

fn queue_status(&self) -> QueueStatus

Get queue status

fn start(&mut self) -> SklResult<()>

Start the scheduler

fn pause(&mut self) -> SklResult<()>

Pause the scheduler

fn resume(&mut self) -> SklResult<()>

Resume the scheduler

fn shutdown(&mut self) -> SklResult<()>

Shutdown the scheduler

fn health_check(&self) -> Health

Get scheduler health

Implementors