Struct DefaultTaskScheduler 

pub struct DefaultTaskScheduler { /* private fields */ }

Default task scheduler implementation

Implementations

impl DefaultTaskScheduler

pub fn new(config: SchedulerConfig) -> Self

Create a new default task scheduler

Trait Implementations

impl TaskScheduler for DefaultTaskScheduler

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

Schedule a single task

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

Schedule multiple tasks as a batch

fn cancel_task(&mut self, handle: TaskHandle) -> SklResult<()>

Cancel a scheduled task

fn get_status(&self) -> SchedulerStatus

Get current scheduler status

fn update_config(&mut self, config: SchedulerConfig) -> SklResult<()>

Update scheduler configuration

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

Get next task to execute (if any)

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

Mark task as completed

fn mark_failed(&mut self, task_id: &str, _error: String) -> SklResult<()>

Mark task as failed

fn get_metrics(&self) -> SchedulingMetrics

Get scheduling metrics