Struct openraft::metrics::RaftMetrics

pub struct RaftMetrics<NID, N>where
    NID: NodeId,
    N: Node,{
    pub running_state: Result<(), Fatal<NID>>,
    pub id: NID,
    pub current_term: u64,
    pub last_log_index: Option<u64>,
    pub last_applied: Option<LogId<NID>>,
    pub snapshot: Option<LogId<NID>>,
    pub state: ServerState,
    pub current_leader: Option<NID>,
    pub membership_config: Arc<StoredMembership<NID, N>>,
    pub replication: Option<Versioned<ReplicationMetrics<NID>>>,
}

A set of metrics describing the current state of a Raft node.

Fields

running_state: Result<(), Fatal<NID>>

id: NID

The ID of the Raft node.

current_term: u64

The current term of the Raft node.

last_log_index: Option<u64>

The last log index has been appended to this Raft node’s log.

last_applied: Option<LogId<NID>>

The last log index has been applied to this Raft node’s state machine.

snapshot: Option<LogId<NID>>

The id of the last log included in snapshot. If there is no snapshot, it is (0,0).

state: ServerState

The state of the Raft node.

current_leader: Option<NID>

The current cluster leader.

membership_config: Arc<StoredMembership<NID, N>>

The current membership config of the cluster.

replication: Option<Versioned<ReplicationMetrics<NID>>>

The metrics about the leader. It is Some() only when this node is leader.

Implementations

impl<NID, N> RaftMetrics<NID, N>where NID: NodeId, N: Node,

pub fn new_initial(id: NID) -> Self

Trait Implementations

impl<NID, N> Clone for RaftMetrics<NID, N>where NID: NodeId + Clone, N: Node + Clone,

fn clone(&self) -> RaftMetrics<NID, N>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<NID, N> Debug for RaftMetrics<NID, N>where NID: NodeId + Debug, N: Node + Debug,

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

Formats the value using the given formatter.

impl<NID, N> MessageSummary<RaftMetrics<NID, N>> for RaftMetrics<NID, N>where NID: NodeId, N: Node,

fn summary(&self) -> String

Return a string of a big message

impl<NID, N> PartialEq<RaftMetrics<NID, N>> for RaftMetrics<NID, N>where NID: NodeId + PartialEq, N: Node + PartialEq,

fn eq(&self, other: &RaftMetrics<NID, N>) -> bool

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

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

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

impl<NID, N> Eq for RaftMetrics<NID, N>where NID: NodeId + Eq, N: Node + Eq,

impl<NID, N> StructuralEq for RaftMetrics<NID, N>where NID: NodeId, N: Node,

impl<NID, N> StructuralPartialEq for RaftMetrics<NID, N>where NID: NodeId, N: Node,