Struct TcpNetworkService 

pub struct TcpNetworkService {
    pub info: RaftNodeInfo,
    pub raft: MaybeLoadingRaft,
    pub service_api: Arc<OnceLock<UnboundedSender<TcpNetworkServiceRequest>>>,
    pub ct: CancellationToken,
}

Fields

info: RaftNodeInfo

raft: MaybeLoadingRaft

service_api: Arc<OnceLock<UnboundedSender<TcpNetworkServiceRequest>>>

ct: CancellationToken

Implementations

impl TcpNetworkService

pub async fn get_connection( &self, peer_id: NodeId, ) -> Option<Arc<RaftTcpConnection>>

pub async fn ensure_connection( &self, peer_id: NodeId, peer_addr: String, ) -> Result<Arc<RaftTcpConnection>>

pub fn run_service(&self)

impl TcpNetworkService

pub fn new( info: RaftNodeInfo, raft: MaybeLoadingRaft, ct: CancellationToken, ) -> Self

pub fn set_raft(&self, raft: Raft<TypeConfig>)

Trait Implementations

impl Clone for TcpNetworkService

fn clone(&self) -> TcpNetworkService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TcpNetworkService

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

Formats the value using the given formatter.

impl RaftNetworkFactory<TypeConfig> for TcpNetworkService

type Network = TcpNetwork

Actual type of the network handling a single connection.

async fn new_client( &mut self, target: <TypeConfig as RaftTypeConfig>::NodeId, node: &<TypeConfig as RaftTypeConfig>::Node, ) -> Self::Network

Create a new network instance sending RPCs to the target node.