Struct NetworkConnection 

pub struct NetworkConnection { /* private fields */ }

Represents an active network connection to a remote Raft node. Handles serialization and deserialization of Raft messages over gRPC.

Implementations

impl NetworkConnection

pub fn new(target_node: <TypeConfig as RaftTypeConfig>::Node) -> Self

Creates a new NetworkConnection with the provided gRPC client.

Trait Implementations

impl NetBackoff<TypeConfig> for NetworkConnection

fn backoff(&self) -> Backoff

Build a backoff instance if the target node is temporarily(or permanently) unreachable.

impl NetSnapshot<TypeConfig> for NetworkConnection

async fn full_snapshot( &mut self, vote: <TypeConfig as RaftTypeConfig>::Vote, snapshot: Snapshot<TypeConfig>, _cancel: impl Future<Output = ReplicationClosed> + OptionalSend + 'static, _option: RPCOption, ) -> Result<SnapshotResponse<TypeConfig>, StreamingError<TypeConfig>>

Send a complete Snapshot to the target.

impl NetStreamAppend<TypeConfig> for NetworkConnection

fn stream_append<'s, S>( &'s mut self, input: S, _option: RPCOption, ) -> BoxFuture<'s, Result<BoxStream<'s, Result<StreamAppendResult<TypeConfig>, RPCError<TypeConfig, Infallible>>>, RPCError<TypeConfig, Infallible>>>

where S: Stream<Item = AppendEntriesRequest<TypeConfig>> + OptionalSend + Unpin + 'static,

Send a stream of AppendEntries RPCs to the target and return a stream of responses.

impl NetTransferLeader<TypeConfig> for NetworkConnection

async fn transfer_leader( &mut self, _req: TransferLeaderRequest<TypeConfig>, _option: RPCOption, ) -> Result<(), RPCError<TypeConfig, Infallible>>

Send TransferLeader message to the target node.

impl NetVote<TypeConfig> for NetworkConnection

async fn vote( &mut self, req: VoteRequest<TypeConfig>, _option: RPCOption, ) -> Result<VoteResponse<TypeConfig>, RPCError<TypeConfig, Infallible>>

Send a RequestVote RPC to the target.