Enum foca::Timer

pub enum Timer<T> {
    ProbeRandomMember(TimerToken),
    SendIndirectProbe {
        probed_id: T,
        token: TimerToken,
    },
    ChangeSuspectToDown {
        member_id: T,
        incarnation: Incarnation,
        token: TimerToken,
    },
    RemoveDown(T),
}

Timer is an event that’s scheduled by a Runtime. You won’t need to construct or understand these, just ensure a timely delivery.

Variants

ProbeRandomMember(TimerToken)

Pick a random active member and initiate the probe cycle.

SendIndirectProbe

Fields

probed_id: T

The current member being probed

token: TimerToken

See TimerToken

Send indirect probes if the direct one hasn’t completed yet.

ChangeSuspectToDown

Fields

member_id: T

Target member identity

incarnation: Incarnation

Its Incarnation the moment the suspicion was raised. If the member refutes the suspicion (by increasing its Incarnation), this won’t match and it won’t be declared Down.

token: TimerToken

See TimerToken

Transitions member T from Suspect to Down if the incarnation is still the same.

RemoveDown(T)

Forgets about dead member T, allowing them to join the cluster again with the same identity.

Trait Implementations

impl<T: Clone> Clone for Timer<T>

fn clone(&self) -> Timer<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for Timer<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for Timer<T> where
    T: Deserialize<'de>, 

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<T: PartialEq> PartialEq<Timer<T>> for Timer<T>

fn eq(&self, other: &Timer<T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Timer<T>) -> bool

This method tests for !=.

impl<T> Serialize for Timer<T> where
    T: Serialize, 

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl<T> StructuralPartialEq for Timer<T>