Struct WorkflowScheduler 

pub struct WorkflowScheduler { /* private fields */ }

Workflow scheduler.

Implementations

impl WorkflowScheduler

pub fn new() -> Self

Create a new scheduler backed by the system wall clock.

pub fn with_clock(clock: Arc<dyn Clock>) -> Self

Create a new scheduler that reads time from the supplied Clock.

Production callers should use Self::new (which uses SystemClock); this constructor exists so tests can inject a deterministic clock and drive cron evaluation at logical times without sleeping.

pub async fn add_schedule( &self, workflow: Workflow, trigger: Trigger, ) -> Result<WorkflowId>

Add a scheduled workflow.

pub async fn remove_schedule(&self, workflow_id: WorkflowId) -> Result<()>

Remove a scheduled workflow.

pub async fn set_schedule_enabled( &self, workflow_id: WorkflowId, enabled: bool, ) -> Result<()>

Enable/disable a schedule.

pub async fn list_schedules(&self) -> Vec<(WorkflowId, ScheduledWorkflow)>

Get all scheduled workflows.

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

Start the scheduler.

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

Stop the scheduler.

pub async fn check_schedules(&self) -> Vec<Workflow>

Check for workflows ready to execute.

pub async fn get_next_execution( &self, workflow_id: WorkflowId, ) -> Option<DateTime<Utc>>

Get next execution time for a workflow.

Trait Implementations

impl Default for WorkflowScheduler

fn default() -> Self

Returns the “default value” for a type.