Struct LeaderEngine 

pub struct LeaderEngine { /* private fields */ }

Implementations

impl LeaderEngine

pub fn new(leaders_ahead: usize, initial_schedule: ScheduleSnapshot) -> Self

pub fn from_buffer( buffer: Arc<LeaderBuffer>, initial_schedule: ScheduleSnapshot, ) -> Self

pub fn buffer(&self) -> Arc<LeaderBuffer>

pub fn active_schedule(&self) -> &ScheduleSnapshot

pub fn last_slot(&self) -> u64

pub fn seed(&mut self, current_slot: u64) -> EngineEvent

pub fn on_slot(&mut self, current_slot: u64) -> EngineEvent

pub fn replace_schedule(&mut self, schedule: ScheduleSnapshot) -> EngineEvent