Struct IrohConnector 

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

Fields

stable: Endpoint

next: Option<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.

Implementations

impl IrohConnector

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

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

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

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

impl IrohConnector

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>> + 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.

impl Debug for IrohConnector

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

Formats the value using the given formatter.