Struct network::connectivity_manager::ConnectivityManager
source · pub struct ConnectivityManager<TBackoff> { /* private fields */ }Expand description
The ConnectivityManager actor.
Implementations§
source§impl<TBackoff> ConnectivityManager<TBackoff>where
TBackoff: Iterator<Item = Duration> + Clone,
impl<TBackoff> ConnectivityManager<TBackoff>where TBackoff: Iterator<Item = Duration> + Clone,
sourcepub fn new(
network_context: Arc<NetworkContext>,
time_service: TimeService,
eligible: Arc<RwLock<PeerSet>>,
seeds: PeerSet,
connection_reqs_tx: ConnectionRequestSender,
connection_notifs_rx: Receiver,
requests_rx: Receiver<ConnectivityRequest>,
connectivity_check_interval: Duration,
backoff_strategy: TBackoff,
max_delay: Duration,
outbound_connection_limit: Option<usize>,
mutual_authentication: bool
) -> Self
pub fn new( network_context: Arc<NetworkContext>, time_service: TimeService, eligible: Arc<RwLock<PeerSet>>, seeds: PeerSet, connection_reqs_tx: ConnectionRequestSender, connection_notifs_rx: Receiver, requests_rx: Receiver<ConnectivityRequest>, connectivity_check_interval: Duration, backoff_strategy: TBackoff, max_delay: Duration, outbound_connection_limit: Option<usize>, mutual_authentication: bool ) -> Self
Creates a new instance of the ConnectivityManager actor.
sourcepub async fn start(self)
pub async fn start(self)
Starts the ConnectivityManager actor.