Struct TcpNetwork 

pub struct TcpNetwork { /* private fields */ }

Implementations

impl TcpNetwork

pub fn new(peer: RaftNodeInfo, source: TcpNetworkService) -> Self

Trait Implementations

impl RaftNetwork<TypeConfig> for TcpNetwork

async fn vote( &mut self, rpc: VoteRequest<<TypeConfig as RaftTypeConfig>::NodeId>, _option: RPCOption, ) -> Result<VoteResponse<<TypeConfig as RaftTypeConfig>::NodeId>, RPCError<<TypeConfig as RaftTypeConfig>::NodeId, <TypeConfig as RaftTypeConfig>::Node, RaftError<<TypeConfig as RaftTypeConfig>::NodeId>>>

Send a RequestVote RPC to the target.

async fn append_entries( &mut self, rpc: AppendEntriesRequest<TypeConfig>, _option: RPCOption, ) -> Result<AppendEntriesResponse<<TypeConfig as RaftTypeConfig>::NodeId>, RPCError<<TypeConfig as RaftTypeConfig>::NodeId, <TypeConfig as RaftTypeConfig>::Node, RaftError<<TypeConfig as RaftTypeConfig>::NodeId>>>

Send an AppendEntries RPC to the target.

async fn install_snapshot( &mut self, rpc: InstallSnapshotRequest<TypeConfig>, _option: RPCOption, ) -> Result<InstallSnapshotResponse<<TypeConfig as RaftTypeConfig>::NodeId>, RPCError<<TypeConfig as RaftTypeConfig>::NodeId, <TypeConfig as RaftTypeConfig>::Node, RaftError<<TypeConfig as RaftTypeConfig>::NodeId, InstallSnapshotError>>>

Send an InstallSnapshot RPC to the target.

fn full_snapshot( &mut self, vote: Vote<<C as RaftTypeConfig>::NodeId>, snapshot: Snapshot<C>, cancel: impl Future<Output = ReplicationClosed> + OptionalSend + 'static, option: RPCOption, ) -> impl Future<Output = Result<SnapshotResponse<<C as RaftTypeConfig>::NodeId>, StreamingError<C, Fatal<<C as RaftTypeConfig>::NodeId>>>> + Send

Send a complete Snapshot to the target.

fn backoff(&self) -> Backoff

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