Struct JobScheduler

pub struct JobScheduler<B: QueueBackend> { /* private fields */ }

Job scheduler manages recurring jobs and their execution

Implementations

impl<B: QueueBackend + 'static> JobScheduler<B>

pub fn new(backend: Arc<B>) -> Self

Create a new job scheduler

pub fn add_schedule(&self, schedule: ScheduledJob) -> ScheduleResult<()>

Add a scheduled job

pub fn remove_schedule(&self, id: &str) -> ScheduleResult<bool>

Remove a scheduled job

pub fn get_schedule(&self, id: &str) -> Option<ScheduledJob>

Get a scheduled job by ID

pub fn list_schedules(&self) -> Vec<ScheduledJob>

List all scheduled jobs

pub fn set_schedule_enabled( &self, id: &str, enabled: bool, ) -> ScheduleResult<bool>

Enable or disable a scheduled job

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

Start the scheduler loop

pub fn stop(&self)

Stop the scheduler

pub fn is_running(&self) -> bool

Check if scheduler is running

pub async fn get_dead_jobs( &self, limit: Option<usize>, ) -> QueueResult<Vec<JobEntry>>

Get dead letter queue entries (jobs that failed permanently)

pub async fn requeue_dead_job(&self, job_id: JobId) -> QueueResult<bool>

Requeue a dead job (reset attempts and change to Pending state)

pub async fn clear_dead_jobs(&self) -> QueueResult<u64>

Clear all dead letter queue entries