Struct CronScheduler 

pub struct CronScheduler { /* private fields */ }

The cron scheduler for time-based autonomous agent execution.

Allows scheduling agents to run on cron-like schedules without user intervention. Supports 5-field (Linux cron) and 6-7 field expressions via the cron crate.

Implementations

impl CronScheduler

pub fn new(state_store: Arc<StateStore>, tick_interval_secs: u64) -> Self

Create a new CronScheduler.

Arguments

• state_store - State store for persisting job definitions
• tick_interval_secs - How often to check for due jobs (in seconds)

pub fn set_max_concurrent_jobs(&mut self, max: usize)

Set the maximum concurrent cron job executions.

pub fn set_job_timeout_secs(&mut self, secs: u64)

Set the timeout for individual cron job execution in seconds.

pub fn set_git_layer(&mut self, gl: Arc<GitLayer>)

Set the git layer for version-controlled saves.

pub async fn add_job(&self, job: CronJob) -> Result<Uuid>

Add a job. Parses schedule, computes next_run, stores.

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

Remove a job by ID.

pub async fn update_job(&self, id: Uuid, update: CronJobUpdate) -> Result<()>

Update a job’s fields (enabled, schedule, goal, etc).

pub async fn toggle_job(&self, id: Uuid, enabled: bool) -> Result<()>

Toggle a job enabled/disabled.

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

List all jobs.

pub fn get_job(&self, id: Uuid) -> Option<CronJob>

Get a single job.

pub fn is_running(&self, id: Uuid) -> bool

Check if a job is currently running.

pub fn trigger_job(&self, id: Uuid) -> Result<CronJob>

Trigger a job immediately (manual execution, ignores schedule). Returns the job goal as a string for the caller to execute. The caller is responsible for calling mark_job_completed after execution.

pub async fn mark_job_completed(&self, id: Uuid, success: bool, summary: String)

Mark a job execution as completed.

pub fn stop(&self)

Stop the scheduler loop.

pub async fn start<F, Fut>(self: Arc<Self>, executor: F)

where F: Fn(Uuid, String) -> Fut + Send + Sync + 'static, Fut: Future<Output = (bool, String)> + Send + 'static,

Start the main loop. Must be called on an Arc<Self>.

Arguments

• executor - Async closure (Uuid, String) -> Fut where args are (job_id, goal), returning (success, summary).

Example

let scheduler = Arc::new(CronScheduler::new(state_store, 60));
scheduler.clone().start(|id, goal| async move {
    // execute the agent...
    (true, "Done".to_string())
}).await;

pub async fn restore_jobs(&self)

Restore jobs from disk on startup.

pub async fn load_from_config(&self, config: &CronConfig)

Load jobs defined in config (called during startup). Config-defined jobs are only added if they don’t already exist (API wins on conflict).

Trait Implementations

impl Clone for CronScheduler

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.