Struct CronScheduler 

pub struct CronScheduler { /* private fields */ }

SurrealDB-backed cron scheduler.

Implementations

impl CronScheduler

pub fn new(memory: Arc<SurrealMemory>) -> Self

Create with a SurrealDB memory backend.

pub fn new_noop() -> Self

Create without memory backend (in-memory only).

pub async fn add( &self, name: &str, schedule: &str, task: &str, channel: &str, chat_id: &str, model: &str, ) -> Result<String>

Add a new cron job. Returns the job ID.

pub async fn add_once( &self, name: &str, run_at: DateTime<Utc>, task: &str, channel: &str, chat_id: &str, model: &str, ) -> Result<String>

pub async fn list(&self) -> Result<Vec<CronJob>>

List all cron jobs.

pub async fn remove(&self, id_or_name: &str) -> Result<bool>

Remove a cron job by ID or name.

pub async fn enable(&self, id_or_name: &str) -> Result<bool>

Enable a cron job.

Enabling is the documented recovery from a dead status, so it also recomputes next_run and clears the status. Setting enabled = true alone leaves a job matching no branch of the due query while list reports it as enabled.

pub async fn disable(&self, id_or_name: &str) -> Result<bool>

Disable a cron job.

pub async fn due_jobs(&self) -> Result<Vec<CronJob>>

Get due jobs (next_run <= now, enabled).

pub async fn claim_due_jobs(&self, channel: &str) -> Result<Vec<CronJob>>

pub async fn mark_run( &self, job_id: &str, run_token: &str, schedule: &str, ) -> Result<()>

Mark a job as just run and compute next_run.

pub async fn release_run(&self, job_id: &str, run_token: &str) -> Result<()>

pub async fn fail_run( &self, job_id: &str, run_token: &str, error: &str, ) -> Result<()>