Struct CronManager 

pub struct CronManager { /* private fields */ }

Cron manager for job scheduling and execution

Implementations

impl CronManager

pub async fn new<P: AsRef<Path>>(workspace: P) -> Result<Self>

Create a new cron manager with file-based storage

pub fn with_store(store: Arc<dyn CronStore>, workspace: String) -> Self

Create a cron manager with a custom store

pub fn set_agent_executor(&mut self, executor: Arc<dyn AgentExecutor>)

Set the agent executor for agent-mode cron jobs.

pub fn subscribe(&self) -> Receiver<SchedulerEvent>

Subscribe to scheduler events

pub async fn add_job( &self, name: &str, schedule: &str, command: &str, ) -> Result<CronJob>

Add a new cron job

pub async fn add_agent_job( &self, name: &str, schedule: &str, prompt: &str, config: AgentJobConfig, ) -> Result<CronJob>

Add a new agent-mode cron job.

The command field is used as the agent prompt. When the job fires, it creates a temporary Agent with the given config and sends the prompt.

pub async fn get_job(&self, id: &str) -> Result<Option<CronJob>>

Get a job by ID

pub async fn get_job_by_name(&self, name: &str) -> Result<Option<CronJob>>

Get a job by name

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

List all jobs

pub async fn update_job( &self, id: &str, schedule: Option<&str>, command: Option<&str>, timeout_ms: Option<u64>, ) -> Result<CronJob>

Update a job

pub async fn pause_job(&self, id: &str) -> Result<CronJob>

Pause a job

pub async fn resume_job(&self, id: &str) -> Result<CronJob>

Resume a paused job

pub async fn remove_job(&self, id: &str) -> Result<()>

Remove a job

pub async fn get_history( &self, job_id: &str, limit: usize, ) -> Result<Vec<JobExecution>>

Get execution history for a job

pub async fn run_job(&self, id: &str) -> Result<JobExecution>

Manually run a job

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

Start the scheduler background task

pub async fn stop(&self)

Stop the scheduler

pub async fn is_running(&self) -> bool

Check if scheduler is running