Struct RedisSchedulerBackend 

pub struct RedisSchedulerBackend { /* private fields */ }

Implementations

impl RedisSchedulerBackend

pub fn new(config: RedisBackendConfig) -> Result<Self, BeatError>

Trait Implementations

impl SchedulerBackend for RedisSchedulerBackend

fn should_sync(&self) -> bool

Check whether the internal state of the scheduler should be synchronized. If this method returns true, then sync will be called as soon as possible.

fn sync( &mut self, _scheduled_tasks: &mut BinaryHeap<ScheduledTask>, ) -> Result<(), BeatError>

Synchronize the internal state of the scheduler.

fn as_distributed(&mut self) -> Option<&mut dyn DistributedScheduler>

Return a mutable reference to the distributed capability of this backend, if any.