Enum ClusterEvent 

#[non_exhaustive]
pub enum ClusterEvent {
    PeerUp {
        peer_id: PeerId,
        dc: String,
        ts: SystemTime,
    },
    PeerDown {
        peer_id: PeerId,
        dc: String,
        phi: f64,
        ts: SystemTime,
    },
    GossipRoundComplete {
        duration: Duration,
        peers_seen: usize,
        ts: SystemTime,
    },
    AaeExchangeStarted {
        with_peer: PeerId,
        partition: TokenRange,
        ts: SystemTime,
    },
    AaeExchangeCompleted {
        with_peer: PeerId,
        partition: TokenRange,
        repaired: u64,
        ts: SystemTime,
    },
    RestartObserved {
        peer_id: PeerId,
        ts: SystemTime,
    },
    RingChanged {
        tag: String,
        ts: SystemTime,
    },
}

Structured cluster-event payload published on the EventManager broadcast.

Variants are non-exhaustive at the type level; consumers must always include a wildcard arm so future additions remain non-breaking.

Examples

use std::time::SystemTime;
use dynomite::events::ClusterEvent;
let e = ClusterEvent::PeerUp { peer_id: 1, dc: "dc1".into(), ts: SystemTime::now() };
match e {
    ClusterEvent::PeerUp { peer_id, .. } => assert_eq!(peer_id, 1),
    _ => panic!("unexpected"),
}

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

PeerUp

A peer transitioned to a routable state.

Fields

peer_id: PeerId

Peer index.

dc: String

Datacenter the peer belongs to.

ts: SystemTime

Wall-clock timestamp at which the engine observed the transition.

PeerDown

A peer transitioned to an unroutable state because the failure detector crossed its phi threshold.

Fields

peer_id: PeerId

Peer index.

dc: String

Datacenter the peer belongs to.

phi: f64

Phi value observed at the moment of the transition.

ts: SystemTime

Wall-clock timestamp at which the engine observed the transition.

GossipRoundComplete

One periodic gossip pass finished.

Fields

duration: Duration

Wall-clock duration spent in the round.

peers_seen: usize

Number of distinct peers visited during the round.

ts: SystemTime

Wall-clock timestamp at which the round finished.

AaeExchangeStarted

An anti-entropy exchange started against a peer.

Fields

with_peer: PeerId

Peer the exchange is running against.

partition: TokenRange

Token range the exchange covers.

ts: SystemTime

Wall-clock timestamp at which the exchange started.

AaeExchangeCompleted

An anti-entropy exchange finished against a peer.

Fields

with_peer: PeerId

Peer the exchange ran against.

partition: TokenRange

Token range the exchange covered.

repaired: u64

Number of keys repaired during the exchange.

ts: SystemTime

Wall-clock timestamp at which the exchange finished.

RestartObserved

A peer was observed restarting (its incarnation changed or its peering session was re-established after a clean shutdown).

Fields

peer_id: PeerId

Peer index.

ts: SystemTime

Wall-clock timestamp at which the restart was observed.

RingChanged

The token ring topology changed: a peer was added, removed, or its tokens were reassigned.

Fields

tag: String

Free-form tag describing the trigger (e.g. "seed-discovery", "reconfigure", "shutdown").

ts: SystemTime

Wall-clock timestamp at which the change was applied.

Trait Implementations

impl Clone for ClusterEvent

fn clone(&self) -> ClusterEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClusterEvent

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

Formats the value using the given formatter.