pub struct RoundRobin<H: Hasher = Sha256> { /* private fields */ }Expand description
Configuration for round-robin leader election.
Rotates through participants based on (epoch + term) % num_participants, where term is the
stable-leader term containing the view.
The rotation order can be shuffled at construction using a seed.
Works with any signing scheme.
Implementations§
Source§impl<H: Hasher> RoundRobin<H>
impl<H: Hasher> RoundRobin<H>
Sourcepub fn shuffled(seed: &[u8]) -> Self
pub fn shuffled(seed: &[u8]) -> Self
Creates a round-robin config that will shuffle the rotation order based on seed.
The seed is used during Config::build to deterministically
shuffle the permutation.
Sourcepub const fn with_term(
self,
term_length: TermLength,
stall_timeout: Duration,
optimistic_views: ViewDelta,
) -> Self
pub const fn with_term( self, term_length: TermLength, stall_timeout: Duration, optimistic_views: ViewDelta, ) -> Self
Enables stable leaders: term_length consecutive views share a leader,
a term abandoned after stall_timeout evicts them, and participants
may run up to optimistic_views ahead within a term (see
Terms::stable).
The term length is consensus-critical: every participant must configure
the same value (see TermLength). The timeout and lookahead are
local policy.
§Panics
Panics if term_length is 1 or stall_timeout is zero (see
Terms::stable).
Trait Implementations§
Source§impl<H: Hasher> Clone for RoundRobin<H>
impl<H: Hasher> Clone for RoundRobin<H>
Auto Trait Implementations§
impl<H> Freeze for RoundRobin<H>where
PhantomData<H>: Freeze,
impl<H> RefUnwindSafe for RoundRobin<H>where
PhantomData<H>: RefUnwindSafe,
impl<H> Send for RoundRobin<H>where
PhantomData<H>: Send,
impl<H> Sync for RoundRobin<H>where
PhantomData<H>: Sync,
impl<H> Unpin for RoundRobin<H>where
PhantomData<H>: Unpin,
impl<H> UnsafeUnpin for RoundRobin<H>where
PhantomData<H>: UnsafeUnpin,
impl<H> UnwindSafe for RoundRobin<H>where
PhantomData<H>: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
impl<A, B, T> HttpServerConnExec<A, B> for Twhere
B: Body,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more