Struct Scheduler 

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

Implementations

impl<S> Scheduler<S, NoopExecutionGuard, NoopCoordinatedStateStore>

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, NoopCoordinatedStateStore>

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<C> Scheduler<InMemoryStateStore, NoopExecutionGuard, C>

where C: CoordinatedStateStore + Send + Sync + 'static,

pub fn with_coordinated_state_store( config: SchedulerConfig, store: C, lease_config: CoordinatedLeaseConfig, ) -> Self

pub fn with_observer_and_coordinated_state_store<O>( config: SchedulerConfig, store: C, observer: O, lease_config: CoordinatedLeaseConfig, ) -> Self

where O: SchedulerObserver,

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

where S: StateStore + Send + Sync + 'static, G: ExecutionGuard + Send + Sync + 'static, C: CoordinatedStateStore + 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,