Struct RaftServiceImpl 

pub struct RaftServiceImpl { /* private fields */ }

Internal gRPC service implementation for Raft protocol communications. This service handles the core Raft consensus protocol operations between cluster nodes.

Responsibilities

• Vote requests/responses during leader election
• Log replication between nodes
• Snapshot installation for state synchronization

Protocol Safety

This service implements critical consensus protocol operations and should only be exposed to other trusted Raft cluster nodes, never to external clients.

Implementations

impl RaftServiceImpl

pub fn new(raft_node: Raft<TypeConfig>) -> Self

Creates a new instance of the internal service

Arguments

• raft_node - The Raft node instance this service will operate on

Trait Implementations

impl RaftService for RaftServiceImpl

fn vote<'life0, 'async_trait>( &'life0 self, request: Request<VoteRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<VoteResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handles vote requests during leader election.

Arguments

• request - The vote request containing candidate information

Returns

• Ok(Response) - Vote response indicating whether the vote was granted
• Err(Status) - Error status if the vote operation fails

Protocol Details

This implements the RequestVote RPC from the Raft protocol. Nodes vote for candidates based on log completeness and term numbers.

fn append_entries<'life0, 'async_trait>( &'life0 self, request: Request<AppendEntriesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AppendEntriesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handles append entries requests for log replication.

Arguments

• request - The append entries request containing log entries to replicate

Returns

• Ok(Response) - Response indicating success/failure of the append operation
• Err(Status) - Error status if the append operation fails

Protocol Details

This implements the AppendEntries RPC from the Raft protocol. Used for both log replication and as heartbeat mechanism.

fn snapshot<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<SnapshotRequest>>, ) -> Pin<Box<dyn Future<Output = Result<Response<SnapshotResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handles snapshot installation requests for state transfer using streaming.

Arguments

• request - Stream of snapshot chunks with metadata

Returns

• Ok(Response) - Response indicating success/failure of snapshot installation
• Err(Status) - Error status if the snapshot operation fails

fn stream_append<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<AppendEntriesRequest>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamAppendStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handles streaming append entries requests for pipeline replication.

This enables efficient pipelining of log replication where multiple AppendEntries requests can be in-flight simultaneously.

type StreamAppendStream = Pin<Box<dyn Stream<Item = Result<AppendEntriesResponse, Status>> + Send>>

Server streaming response type for the StreamAppend method.