pub enum WorkerState {
Pending,
Active,
Leaving,
Removed,
}Expand description
Lifecycle state of a single worker in the elastic group.
The legal transitions form the chain Pending -> Active -> Leaving -> Removed,
with one extra edge Removed -> Pending so a worker may rejoin after leaving.
Variants§
Pending
The worker has requested to join and is waiting at the rendezvous barrier.
Active
The worker is an active member of the current rendezvous.
Leaving
The worker has requested to leave and is draining out of the group.
Removed
The worker has fully left the group (and may later rejoin).
Implementations§
Source§impl WorkerState
impl WorkerState
Sourcepub fn is_legal_transition(from: Option<WorkerState>, to: WorkerState) -> bool
pub fn is_legal_transition(from: Option<WorkerState>, to: WorkerState) -> bool
Whether from -> to is a legal worker-lifecycle transition.
from == None denotes a worker the coordinator has never seen.
Trait Implementations§
Source§impl Clone for WorkerState
impl Clone for WorkerState
Source§fn clone(&self) -> WorkerState
fn clone(&self) -> WorkerState
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreimpl Copy for WorkerState
Source§impl Debug for WorkerState
impl Debug for WorkerState
impl Eq for WorkerState
Source§impl PartialEq for WorkerState
impl PartialEq for WorkerState
impl StructuralPartialEq for WorkerState
Auto Trait Implementations§
impl Freeze for WorkerState
impl RefUnwindSafe for WorkerState
impl Send for WorkerState
impl Sync for WorkerState
impl Unpin for WorkerState
impl UnsafeUnpin for WorkerState
impl UnwindSafe for WorkerState
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
Mutably borrows from an owned value. Read more
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<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
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> ⓘ
Converts
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> ⓘ
Converts
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 moreSource§impl<T> Pointable for T
impl<T> Pointable for T
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
impl<T> Scalar for T
Source§impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
Source§fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
The inverse inclusion map: attempts to construct
self from the equivalent element of its
superset. Read moreSource§fn is_in_subset(&self) -> bool
fn is_in_subset(&self) -> bool
Checks if
self is actually part of its subset T (and can be converted to it).Source§fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
Use with care! Same as
self.to_subset but without any property checks. Always succeeds.Source§fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
The inclusion map: converts
self to the equivalent element of its superset.