Struct ReplicationEngine 

pub struct ReplicationEngine { /* private fields */ }

The main replication engine.

Implementations

impl ReplicationEngine

pub fn new(local_node: NodeInfo, config: ReplicationConfig) -> Self

Create a new replication engine.

pub fn node_id(&self) -> NodeId

Get the node ID.

pub fn role(&self) -> NodeRole

Get the current role.

pub fn is_leader(&self) -> bool

Check if this node is the leader.

pub fn leader_id(&self) -> Option<NodeId>

Get the current leader ID.

pub fn current_term(&self) -> u64

Get the current term.

pub fn cluster_state(&self) -> ClusterState

Get cluster state.

pub fn cluster_stats(&self) -> ClusterStats

Get cluster stats.

pub fn add_peer(&self, peer: NodeInfo) -> Result<(), ClusterError>

Add a peer to the cluster.

pub fn remove_peer(&self, peer_id: &NodeId) -> Result<NodeInfo, ClusterError>

Remove a peer from the cluster.

pub fn peers(&self) -> Vec<NodeInfo>

Get all peers.

pub fn peer_ids(&self) -> Vec<NodeId>

Get peer IDs.

pub fn propose(&mut self, command: Command) -> Result<u64, ReplicationError>

Propose a command to the cluster.

pub fn get(&self, key: &str) -> Option<Vec<u8>>

Get a value from the state machine.

pub fn set( &mut self, key: impl Into<String>, value: Vec<u8>, ) -> Result<u64, ReplicationError>

Set a value (proposes to cluster if leader).

pub fn delete( &mut self, key: impl Into<String>, ) -> Result<u64, ReplicationError>

Delete a value (proposes to cluster if leader).

pub fn apply_committed(&self) -> Vec<CommandResult>

Apply committed entries to the state machine.

pub fn tick(&mut self) -> TickResult

Process a tick of the event loop.

pub fn start_election(&self) -> VoteRequest

Start an election.

pub fn handle_vote_request(&self, request: &VoteRequest) -> VoteResponse

Handle a vote request.

pub fn handle_vote_response(&self, response: &VoteResponse) -> bool

Handle a vote response.

pub fn create_append_entries_for_peers( &self, ) -> Vec<(NodeId, AppendEntriesRequest)>

Create append entries requests for all peers.

pub fn handle_append_entries( &self, request: &AppendEntriesRequest, ) -> AppendEntriesResponse

Handle an append entries request.

pub fn handle_append_entries_response( &self, peer_id: &NodeId, response: &AppendEntriesResponse, )

Handle an append entries response.

pub fn update_health(&self, health: NodeHealth)

Update health for a node.

pub fn heartbeat(&self, peer_id: &NodeId)

Report heartbeat from a peer.

pub fn process_message(&mut self, message: Message) -> Option<Message>

Process incoming message.

pub fn send_heartbeats(&self, transport: &dyn Transport)

Send messages to peers using transport.

pub fn broadcast_election(&self, transport: &dyn Transport)

Broadcast election request.

pub fn raft(&self) -> &RaftNode

Get the Raft node.

pub fn cluster(&self) -> &Cluster

Get the cluster.

pub fn config(&self) -> &ReplicationConfig

Get the configuration.