Struct TaskExecutor 

pub struct TaskExecutor { /* private fields */ }

Task executor responsible for running tasks

Implementations

impl TaskExecutor

pub fn new(config: ExecutorConfig) -> Self

pub async fn execute_task( &self, task: Arc<Task>, scheduled_time: SystemTime, ) -> Result<String, SchedulerError>

Execute a task asynchronously

pub async fn cancel_task( &self, execution_id: &str, ) -> Result<(), SchedulerError>

Cancel a running task

pub async fn get_execution(&self, execution_id: &str) -> Option<TaskExecution>

Get task execution status

pub async fn get_task_executions(&self, task_id: &str) -> Vec<TaskExecution>

Get all executions for a task

pub async fn get_metrics(&self) -> ExecutionMetrics

Get current metrics

pub async fn running_task_count(&self) -> usize

Get number of running tasks

pub async fn cleanup_old_executions(&self, older_than: Duration)

Clean up completed executions older than the specified duration

pub async fn execute_task_with_delay( &self, task: Arc<Task>, scheduled_time: SystemTime, execution_delay: Option<Duration>, ) -> Result<String, SchedulerError>