Enum ServerEvent 

#[non_exhaustive]
pub enum ServerEvent {
    PeerUp(PeerId),
    PeerDown {
        peer: PeerId,
        reason: PeerDownReason,
    },
    ConfigReloaded {
        generation: u64,
    },
    GossipRound {
        round: u64,
        peers: u32,
    },
    AutoEjected {
        peer: PeerId,
        failures: u32,
    },
    RepairTriggered {
        key_hash: u64,
        dc: String,
    },
    ConnectionAccepted {
        conn_id: ConnId,
        role: ConnRoleTag,
        local_addr: Option<SocketAddr>,
    },
    ConnectionClosed {
        conn_id: ConnId,
        reason: CloseReason,
    },
    Lagged {
        missed: u64,
    },
}

Cluster-wide event published on the broadcast channel.

The variants are non-exhaustive at the type level; consumers must use a wildcard arm so future additions remain non-breaking.

Examples

use dynomite::embed::events::{ServerEvent, PeerDownReason};
let e = ServerEvent::PeerDown { peer: 7, reason: PeerDownReason::FailureDetector };
match e {
    ServerEvent::PeerDown { peer, .. } => assert_eq!(peer, 7),
    _ => panic!(),
}

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(PeerId)

A peer transitioned to a routable state.

PeerDown

A peer transitioned to an unroutable state.

Fields

peer: PeerId

Peer index.

reason: PeerDownReason

Why the transition fired.

ConfigReloaded

A configuration reload completed successfully.

Fields

generation: u64

Monotonic generation id.

GossipRound

A periodic gossip pass finished.

Fields

round: u64

Round number (monotonic).

peers: u32

Number of distinct peers known after the round.

AutoEjected

Auto-eject policy ejected a peer.

Fields

peer: PeerId

Peer index.

failures: u32

Failure count at eject time.

RepairTriggered

Read-repair was triggered for a key.

Fields

key_hash: u64

Hash of the key whose responses diverged.

dc: String

Datacenter that initiated the repair.

ConnectionAccepted

A connection was accepted on a listener.

Fields

conn_id: ConnId

Synthetic connection id.

role: ConnRoleTag

Role of the accepted connection.

local_addr: Option<SocketAddr>

Local socket address; None for non-socket transports.

ConnectionClosed

A connection closed.

Fields

conn_id: ConnId

Connection id from the prior ConnectionAccepted.

reason: CloseReason

Why the connection closed.

Lagged

The receiver fell behind the broadcast tail and missed missed events. The next recv will resume from the freshest event in the buffer.

Fields

missed: u64

Number of events the receiver missed.

Trait Implementations

impl Clone for ServerEvent

fn clone(&self) -> ServerEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServerEvent

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

Formats the value using the given formatter.