Struct ReplicationHandler 

pub struct ReplicationHandler<T>
where
    T: TypeConfig,
{
    pub my_id: u32,
    /* private fields */
}

Fields

my_id: u32

Implementations

impl<T> ReplicationHandler<T>

where T: TypeConfig,

pub fn new(my_id: u32) -> Self

pub async fn generate_new_entries( &self, entry_payloads: Vec<EntryPayload>, current_term: u64, raft_log: &Arc<ROF<T>>, ) -> Result<Vec<Entry>>

Generate a new log entry including insert them into local raft log

pub fn prepare_peer_entries( &self, new_entries: &[Entry], data: &ReplicationData, max_legacy_entries: u64, raft_log: &Arc<ROF<T>>, ) -> DashMap<u32, Vec<Entry>>

Prepare the items that need to be synchronized for each node

pub fn build_append_request( &self, raft_log: &Arc<ROF<T>>, peer_id: u32, entries_per_peer: &DashMap<u32, Vec<Entry>>, data: &ReplicationData, ) -> (u32, AppendEntriesRequest)

Build an append request for a single node

Trait Implementations

impl<T> Clone for ReplicationHandler<T>

where T: TypeConfig + Clone,

fn clone(&self) -> ReplicationHandler<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for ReplicationHandler<T>

where T: TypeConfig,

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

Formats the value using the given formatter.

impl<T> ReplicationCore<T> for ReplicationHandler<T>

where T: TypeConfig,

fn handle_append_entries<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, request: AppendEntriesRequest, state_snapshot: &'life1 StateSnapshot, raft_log: &'life2 Arc<ROF<T>>, ) -> Pin<Box<dyn Future<Output = Result<AppendResponseWithUpdates>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

As Follower only

fn if_update_commit_index_as_follower( my_commit_index: u64, last_raft_log_id: u64, leader_commit_index: u64, ) -> Option<u64>

If leaderCommit > commitIndex, set commitIndex = min(leaderCommit, index of last new entry)

fn handle_raft_request_in_batch<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, entry_payloads: Vec<EntryPayload>, state_snapshot: StateSnapshot, leader_state_snapshot: LeaderStateSnapshot, cluster_metadata: &'life1 ClusterMetadata, ctx: &'life2 RaftContext<T>, ) -> Pin<Box<dyn Future<Output = Result<AppendResults>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

As Leader, send replications to peers (combines regular heartbeats and client proposals).

fn handle_success_response( &self, peer_id: u32, peer_term: u64, success_result: SuccessResult, leader_term: u64, ) -> Result<PeerUpdate>

Handles successful AppendEntries responses

fn handle_conflict_response( &self, peer_id: u32, conflict_result: ConflictResult, raft_log: &Arc<ROF<T>>, current_next_index: u64, ) -> Result<PeerUpdate>

Resolves log conflicts from follower responses

fn retrieve_to_be_synced_logs_for_peers( &self, new_entries: Vec<Entry>, leader_last_index_before_inserting_new_entries: u64, max_legacy_entries_per_peer: u64, peer_next_indices: &HashMap<u32, u64>, raft_log: &Arc<ROF<T>>, ) -> DashMap<u32, Vec<Entry>>

Gathers legacy logs for lagging peers

fn check_append_entries_request_is_legal( &self, my_term: u64, request: &AppendEntriesRequest, raft_log: &Arc<ROF<T>>, ) -> AppendEntriesResponse

Validates an incoming AppendEntries RPC from a Leader against Raft protocol rules.