Struct nimiq_network::connection::connection_pool::ConnectionPool

pub struct ConnectionPool {
    pub notifier: RwLock<PassThroughNotifier<'static, ConnectionPoolEvent>>,
    // some fields omitted
}

Fields

notifier: RwLock<PassThroughNotifier<'static, ConnectionPoolEvent>>

Methods

impl ConnectionPool

pub fn new(
    peer_address_book: Arc<PeerAddressBook>,
    network_config: Arc<NetworkConfig>,
    blockchain: Arc<Blockchain<'static>>
) -> Result<Arc<Self>, Error>

Constructor.

pub fn initialize(&self) -> Result<(), Error>

Initialises necessary threads.

pub fn connect_outbound(&self, peer_address: Arc<PeerAddress>) -> bool

Initiates a outbound connection.

pub fn disconnect(&self)

pub fn state(&self) -> RwLockReadGuard<ConnectionPoolState>

Returns a mapped RwLockReadGuard for the internal state.

pub fn peer_count(&self) -> usize

Total peer count.

pub fn connecting_count(&self) -> usize

Connecting count.

pub fn count(&self) -> usize

pub fn peer_count_outbound(&self) -> usize

pub fn allow_inbound_exchange(&self) -> bool

pub fn allow_inbound_connections(&self) -> bool

pub fn set_allow_inbound_exchange(&self, allow_inbound_exchange: bool)

pub fn set_allow_inbound_connections(&self, allow_inbound_connections: bool)