Struct TaskScheduler

pub struct TaskScheduler { /* private fields */ }

Main task scheduler

Implementations

impl TaskScheduler

pub fn new(config: SchedulerConfig) -> Self

Create a new task scheduler

pub async fn start(&self) -> SchedulerResult<()>

Start the scheduler

pub async fn stop(&self) -> SchedulerResult<()>

Stop the scheduler

pub async fn schedule_job( &self, task: Arc<Task>, trigger: Arc<dyn Trigger>, ) -> SchedulerResult<String>

Schedule a new job

pub async fn schedule_job_with_id( &self, job_id: impl Into<String>, task: Arc<Task>, trigger: Arc<dyn Trigger>, ) -> SchedulerResult<String>

Schedule a job with a specific ID

pub async fn unschedule_job(&self, job_id: &str) -> SchedulerResult<()>

Unschedule a job

pub async fn set_job_enabled( &self, job_id: &str, enabled: bool, ) -> SchedulerResult<()>

Enable or disable a job

pub async fn get_job(&self, job_id: &str) -> Option<ScheduledJob>

Get job information

pub async fn get_all_jobs(&self) -> Vec<ScheduledJob>

Get all jobs

pub async fn get_jobs_by_group(&self, group: &str) -> Vec<ScheduledJob>

Get jobs by task group

pub async fn execute_job_now(&self, job_id: &str) -> SchedulerResult<String>

Execute a job immediately (ad-hoc execution)

pub async fn schedule_delayed_job( &self, task: Arc<Task>, delay: Duration, ) -> SchedulerResult<String>

Schedule a delayed job (execute once after delay)

pub async fn schedule_delayed_job_with_id( &self, job_id: impl Into<String>, task: Arc<Task>, delay: Duration, ) -> SchedulerResult<String>

Schedule a delayed job with specific ID

pub async fn schedule_interval_job_with_delay( &self, task: Arc<Task>, interval: Duration, initial_delay: Duration, ) -> SchedulerResult<String>

Schedule an interval job with initial delay

pub async fn schedule_interval_job_with_delay_and_id( &self, job_id: impl Into<String>, task: Arc<Task>, interval: Duration, initial_delay: Duration, ) -> SchedulerResult<String>

Schedule an interval job with initial delay and specific ID

pub async fn execute_job_now_with_delay( &self, job_id: &str, execution_delay: Option<Duration>, ) -> SchedulerResult<String>

Execute a job immediately with optional execution delay

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

Get task execution

pub async fn cancel_execution(&self, execution_id: &str) -> SchedulerResult<()>

Cancel a running task execution

pub async fn get_status(&self) -> SchedulerStatus

Get scheduler status

Trait Implementations

impl Default for TaskScheduler

fn default() -> Self

Returns the “default value” for a type.