Struct HttpConnection 

pub struct HttpConnection<C: RaftTypeConfig<NodeId = NodeId>> { /* private fields */ }

A single connection to a Raft peer.

Trait Implementations

impl<C> RaftNetwork<C> for HttpConnection<C>

where C: RaftTypeConfig<NodeId = NodeId, Node = BasicNode, SnapshotData = Cursor<Vec<u8>>>, C::D: Serialize + DeserializeOwned, C::R: Serialize + DeserializeOwned, C::Entry: Serialize + DeserializeOwned,

async fn append_entries( &mut self, rpc: AppendEntriesRequest<C>, _option: RPCOption, ) -> Result<AppendEntriesResponse<NodeId>, RPCError<NodeId, BasicNode, RaftError<NodeId>>>

Send an AppendEntries RPC to the target.

async fn install_snapshot( &mut self, rpc: InstallSnapshotRequest<C>, _option: RPCOption, ) -> Result<InstallSnapshotResponse<NodeId>, RPCError<NodeId, BasicNode, RaftError<NodeId, InstallSnapshotError>>>

Send an InstallSnapshot RPC to the target.

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

Send a RequestVote RPC to the target.

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

Send a complete Snapshot to the target.

fn backoff(&self) -> Backoff

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