Struct IrohConnector 

pub(crate) struct IrohConnector {
    stable: Endpoint,
    next: Endpoint,
    connection_overrides: BTreeMap<NodeId, NodeAddr>,
    path_change: Arc<Sender<u64>>,
    next_connections: Arc<Mutex<BTreeMap<NodeId, Connection>>>,
}

Fields

stable: Endpoint

next: Endpoint

connection_overrides: BTreeMap<NodeId, NodeAddr>

List of overrides to use when attempting to connect to given NodeId

This is useful for testing, or forcing non-default network connectivity.

path_change: Arc<Sender<u64>>

Registry-owned signal bumped whenever any per-connection monitoring task observes a transport-level path change (e.g. iroh relay → direct). Consumers of crate::ConnectorRegistry subscribe via crate::ConnectorRegistry::connectivity_change_notifier.

next_connections: Arc<Mutex<BTreeMap<NodeId, Connection>>>

Live connections dialed over the next stack, kept so crate::Connector::connectivity can read their paths back.

Iroh 1.0 exposes path state per connection rather than per endpoint, so unlike the stable stack there is no endpoint.conn_type(node_id) to consult after the fact. Entries are keyed by the stable [NodeId] because that is what callers derive from a peer url, and are replaced on redial, so the map stays bounded by the number of distinct peers.

Implementations

impl IrohConnector

pub(crate) async fn new( iroh_dns: Option<SafeUrl>, iroh_enable_dht: bool, path_change: Arc<Sender<u64>>, ) -> Result<Self>

pub(crate) async fn new_no_overrides( iroh_dns: Option<SafeUrl>, iroh_enable_dht: bool, path_change: Arc<Sender<u64>>, ) -> Result<Self>

pub(crate) fn with_connection_override( self, node: NodeId, addr: NodeAddr, ) -> Self

pub(crate) fn node_id_from_url(url: &SafeUrl) -> Result<NodeId, ConnectorError>

impl IrohConnector

fn connectivity_next(&self, node_id: NodeId) -> Option<Connectivity>

Report how a retained next-stack connection is reaching node_id.

Returns None when the next stack has nothing to say about the peer, so the caller can fall back to the stable stack: no connection held, one that has since closed, or one whose paths cannot be classified. None of those mean “disconnected”, which is what answering Connectivity::Unknown would tell callers.

fn iroh_peer_info_from_conn_type( &self, node_id: NodeId, conn_type: ConnectionType, ) -> IrohPeerInfo

fn spawn_connection_monitoring_stable( endpoint: &Endpoint, node_id: NodeId, path_change: Arc<Sender<u64>>, )

fn spawn_connection_monitoring_next( conn: &Connection, node_id: EndpointId, path_change: Arc<Sender<u64>>, )

async fn make_new_connection_stable( &self, node_id: NodeId, node_addr: Option<NodeAddr>, ) -> ServerResult<Connection>

async fn make_new_connection_next( &self, endpoint_next: &Endpoint, node_id: NodeId, node_addr: Option<NodeAddr>, ) -> ServerResult<Connection>

Trait Implementations

impl Clone for IrohConnector

fn clone(&self) -> IrohConnector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Connector for IrohConnector

fn connect_guardian<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, url: &'life1 SafeUrl, api_secret: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = ServerResult<DynGuaridianConnection>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn connect_gateway<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 SafeUrl, ) -> Pin<Box<dyn Future<Output = Result<DynGatewayConnection, ConnectorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn connectivity(&self, url: &SafeUrl) -> Connectivity

Report how a connection to url is currently reaching its peer.

fn iroh_peer_info<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 SafeUrl, path_timeout: Duration, ) -> Pin<Box<dyn Future<Output = ServerResult<Option<IrohPeerInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return iroh-specific peer details if this connector supports them.

impl Debug for IrohConnector

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

Formats the value using the given formatter.