Struct Scheduler 

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

Implementations

impl<S> Scheduler<S, NoopExecutionGuard>

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,

impl<S, G> Scheduler<S, G>

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

pub fn with_execution_guard(config: SchedulerConfig, store: S, guard: G) -> Self

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

where O: SchedulerObserver,

impl<S, G> Scheduler<S, G>

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

pub fn handle(&self) -> SchedulerHandle

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

where D: Send + Sync + 'static,