Skip to main content

LeaderProvider

Trait LeaderProvider 

Source
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§

Source

fn current_leader(&self) -> Option<LeaderTarget>

Returns the currently scheduled leader target.

Source

fn next_leaders(&self, n: usize) -> Vec<LeaderTarget>

Returns up to n upcoming leader targets.

Implementors§