Struct Scheduler 

pub struct Scheduler<S>
where
    S: StateStore,
{ /* private fields */ }

Implementations

impl<S> Scheduler<S>

where S: StateStore + Send + Sync + 'static,

pub fn new(config: SchedulerConfig, store: S) -> Self

pub fn with_log_observer(config: SchedulerConfig, store: S) -> Self

pub fn with_observer<O>(config: SchedulerConfig, store: S, observer: O) -> Self

where O: SchedulerObserver,

pub fn handle(&self) -> SchedulerHandle

pub async fn run<D>( &self, job: Job<D>, ) -> Result<SchedulerReport, SchedulerError>

where D: Send + Sync + 'static,