pub trait LeaderProvider: Send + Sync {
// Required methods
fn current_leader(&self) -> Option<LeaderTarget>;
fn next_leaders(&self, n: usize) -> Vec<LeaderTarget>;
}Expand description
Source of current/next leader targets.
Required Methods§
Sourcefn current_leader(&self) -> Option<LeaderTarget>
fn current_leader(&self) -> Option<LeaderTarget>
Returns the currently scheduled leader target.
Sourcefn next_leaders(&self, n: usize) -> Vec<LeaderTarget>
fn next_leaders(&self, n: usize) -> Vec<LeaderTarget>
Returns up to n upcoming leader targets.