Struct Scheduler 

pub struct Scheduler { /* private fields */ }

Session-scoped cron scheduler.

Implementations

impl Scheduler

pub fn new(session_id: impl Into<String>) -> Self

Create an empty scheduler bound to session_id. Honors the CLAUDE_DISABLE_VAR / ALIAS_DISABLE_VAR env vars.

pub fn with_cap(session_id: impl Into<String>, cap: usize) -> Self

pub fn restore(session_id: impl Into<String>) -> Self

Restore tasks from disk for session_id. Tasks that have already expired are pruned during the restore.

pub fn session_id(&self) -> &str

pub fn is_disabled(&self) -> bool

pub fn cap(&self) -> usize

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn create( &mut self, schedule: Schedule, prompt: impl Into<String>, recurring: bool, ) -> Result<TaskId, SchedulerError>

Schedule a new task.

recurring=false makes the task one-shot — it’s removed after firing. recurring=true is only meaningful for Schedule::Cron and Schedule::Dynamic; for Schedule::Once it is treated as one-shot regardless.

pub fn list(&self) -> Vec<&Task>

pub fn delete(&mut self, id: &TaskId) -> bool

pub fn tick(&mut self, now: DateTime<Utc>) -> Vec<Fire>

Advance the scheduler to now. Returns the prompts that just fired, in fire-time order. Recurring tasks have their next_fire advanced to the next slot (with jitter); one-shot tasks are removed.

Trait Implementations

impl Debug for Scheduler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.