Struct FlowScheduler 

pub struct FlowScheduler { /* private fields */ }

Scheduler that scans durable state once and enqueues one task per due run.

Implementations

impl FlowScheduler

pub fn new(engine: FlowEngine, dispatcher: Arc<dyn FlowTaskDispatcher>) -> Self

pub fn engine(&self) -> &FlowEngine

pub fn dispatcher(&self) -> Arc<dyn FlowTaskDispatcher>

pub fn queue(&self) -> Arc<dyn FlowTaskDispatcher>

👎Deprecated since 0.4.4:

use dispatcher()

Backward-compatible name for Self::dispatcher.

pub async fn next_wakeup( &self, now: DateTime<Utc>, ) -> Result<Option<WorkflowRunSuspension>>

Return the earliest wait or delayed retry that can wake the scheduler.

pub async fn next_wakeup_delay( &self, now: DateTime<Utc>, ) -> Result<Option<Duration>>

Return how long the host can sleep before the next scheduled wake-up.

Due or overdue wake-ups return Duration::ZERO. Active hooks are not represented because external callbacks are pushed into the queue by the callback router instead of time.

pub async fn enqueue_due_work( &self, now: DateTime<Utc>, ) -> Result<FlowSchedulerTick>

Trait Implementations

impl Clone for FlowScheduler

fn clone(&self) -> FlowScheduler

Returns a duplicate of the value.

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

Performs copy-assignment from source.