Struct MetadataConsensus 

pub struct MetadataConsensus { /* private fields */ }

Metadata consensus using Raft for authoritative state.

Wraps raft-style log replication for service registry and process table consensus. When the cluster feature is active, this can be backed by ruvector_raft::RaftNode; otherwise a self-contained state machine is used.

Implementations

impl MetadataConsensus

pub fn new() -> Self

Create a new consensus instance starting as a follower.

pub fn role(&self) -> ConsensusRole

Current role.

pub fn term(&self) -> u64

Current term.

pub fn commit_index(&self) -> u64

Committed log index.

pub fn set_role(&mut self, role: ConsensusRole)

Transition to a new role.

pub fn advance_term(&mut self, new_term: u64)

Advance to a new term (resets vote state).

pub fn append(&mut self, operation: ConsensusOp) -> u64

Append an entry to the log. Returns the index of the newly appended entry.

pub fn commit(&mut self, up_to: u64) -> Vec<&ConsensusEntry>

Commit entries up to the given index. Returns the newly committed entries.

pub fn entries(&self) -> &[ConsensusEntry]

Get all entries in the log.

pub fn log_len(&self) -> usize

Number of log entries.

Trait Implementations

impl Default for MetadataConsensus

fn default() -> Self

Returns the “default value” for a type.