Struct network::connectivity_manager::ConnectivityManager

pub struct ConnectivityManager<TBackoff> { /* fields omitted */ }

The ConnectivityManager actor.

Implementations

impl<TBackoff> ConnectivityManager<TBackoff> where
    TBackoff: Iterator<Item = Duration> + Clone, 

pub fn new(
    network_context: 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.

pub async fn start(self)

Starts the ConnectivityManager actor.