Struct Connector 

pub struct Connector<C: Codec<ByteBuffer> + Default + Clone> {
    key_pair: KeyPair,
    task_group: TaskGroup,
    connection_slots: Arc<ConnectionSlots>,
    max_retries: usize,
    conn_queue: Option<Arc<ConnQueue>>,
    monitor: Arc<Monitor>,
    _codec: PhantomData<C>,
}

Creates outbound connections with other peers. Generic over the codec applied to the resulting framed stream so the same machinery (TLS, retries, slots, monitor events) serves both the peer data-plane (PeerNetMsgCodec) and the kademlia lookup-plane (KadNetMsgCodec).

Fields

key_pair: KeyPair

task_group: TaskGroup

connection_slots: Arc<ConnectionSlots>

max_retries: usize

conn_queue: Option<Arc<ConnQueue>>

monitor: Arc<Monitor>

_codec: PhantomData<C>

Implementations

impl<C> Connector<C>

where C: Codec<ByteBuffer, Error = Error> + Default + Clone + Send + Sync + 'static,

pub fn new( key_pair: &KeyPair, max_retries: usize, connection_slots: Arc<ConnectionSlots>, monitor: Arc<Monitor>, ex: Executor, ) -> Arc<Self>

Create a new Connector without a ConnQueue (used for plain connect paths like Kademlia lookup).

pub async fn shutdown(&self)

pub async fn connect( &self, endpoint: &Endpoint, peer_id: &Option<PeerID>, ) -> Result<FramedConn<C>>

Connect and return the framed connection.

async fn connect_internal( &self, endpoint: &Endpoint, peer_id: &Option<PeerID>, ) -> Result<DialResult<C>>

Dial with retries.

async fn dial( &self, endpoint: &Endpoint, peer_id: &Option<PeerID>, ) -> Result<DialResult<C>>

Dial, selecting transport based on endpoint type.

impl Connector<PeerNetMsgCodec>

pub fn new_with_queue( key_pair: &KeyPair, max_retries: usize, connection_slots: Arc<ConnectionSlots>, conn_queue: Arc<ConnQueue>, monitor: Arc<Monitor>, ex: Executor, ) -> Arc<Self>

Create a new Connector with a ConnQueue.

pub async fn connect_and_queue( self: &Arc<Self>, endpoint: &Endpoint, peer_id: &Option<PeerID>, ) -> Result<()>

Connect, queue for handshake, and run until the peer disconnects. Disconnect/handshake-failure is observable via PeerPool::register_peer_events, not via this call.