Enum RotationGate 

pub enum RotationGate {
    Local(LocalRotation),
    Peer {
        generation: NonZeroU64,
    },
    LocalAndPeer {
        local: LocalRotation,
        peer_generation: NonZeroU64,
    },
}

Variants

Local(LocalRotation)

This device’s own rotation, with no unadopted peer generation.

Peer

A generation the store committed that this device has not adopted, with no local rotation of its own.

Fields

generation: NonZeroU64

LocalAndPeer

Both facts at once: this device’s rotation, and a peer generation it has not adopted.

Fields

local: LocalRotation

peer_generation: NonZeroU64

Implementations

impl RotationGate

pub fn pending_state(&self) -> RotationPendingState

pub fn with_candidate( gate: Option<Self>, generation: u64, mutation: ObjectHash, ) -> Result<Self, RotationGateError>

Stage mutation as this device’s rotation candidate, on whatever gate is already open (None when none is).

pub fn commit_candidate( gate: Option<Self>, generation: u64, mutation: ObjectHash, ) -> Result<Self, RotationGateError>

Promote this device’s staged candidate to its committed rotation.

pub fn merge_peer_commit( gate: Option<Self>, generation: u64, ) -> Result<Self, RotationGateError>

Record that the store committed generation. Forward-only: an older generation never displaces a newer one already recorded.

pub fn remove_candidate( self, generation: u64, mutation: ObjectHash, ) -> Result<Option<Self>, RotationGateError>

pub fn replace_candidate_mutation( self, generation: u64, previous: ObjectHash, replacement: ObjectHash, ) -> Result<Self, RotationGateError>

pub fn complete_local_adoption( self, generation: u64, mutation: ObjectHash, ) -> Result<Option<Self>, RotationGateError>

pub fn complete_peer_adoption( self, adopted_generation: u64, ) -> Result<Option<Self>, RotationGateError>

pub fn generation(&self) -> NonZeroU64

The newest generation the gate names. Reported through the replication layer’s PendingRotation::pending_generation.

Trait Implementations

impl Clone for RotationGate

fn clone(&self) -> RotationGate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RotationGate

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RotationGate

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RotationGate

fn eq(&self, other: &RotationGate) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for RotationGate

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for RotationGate

impl StructuralPartialEq for RotationGate