Struct Iroh

pub struct Iroh {
    pub(crate) router: Router,
    pub(crate) gossip: Gossip,
    pub(crate) sequence_numbers: Mutex<HashMap<TopicId, i32>>,
    pub(crate) iroh_channels: RwLock<HashMap<TopicId, ChannelState>>,
    pub(crate) public_key: PublicKey,
}

Store Iroh peer channels for the context.

Fields

router: Router

Iroh router needed for Iroh peer channels.

gossip: Gossip

[Gossip] needed for Iroh peer channels.

sequence_numbers: Mutex<HashMap<TopicId, i32>>

Sequence numbers for gossip channels.

iroh_channels: RwLock<HashMap<TopicId, ChannelState>>

Topics for which an advertisement has already been sent.

public_key: PublicKey

Currently used Iroh public key.

This is attached to every message to work around iroh_gossip deduplication.

Implementations

impl Iroh

pub(crate) async fn network_change(&self)

Notify the endpoint that the network has changed.

pub(crate) async fn close(self) -> Result<()>

Closes the QUIC endpoint.

async fn join_and_subscribe_gossip( &self, ctx: &Context, msg_id: MsgId, ) -> Result<Option<Receiver<()>>>

Join a topic and create the subscriber loop for it.

If there is no gossip, create it.

The returned future resolves when the swarm becomes operational.

pub async fn maybe_add_gossip_peer( &self, topic: TopicId, peer: NodeAddr, ) -> Result<()>

Add gossip peer to realtime channel if it is already active.

pub async fn send_webxdc_realtime_data( &self, ctx: &Context, msg_id: MsgId, data: Vec<u8>, ) -> Result<()>

Send realtime data to the gossip swarm.

fn get_and_incr(&self, topic: &TopicId) -> i32

pub(crate) async fn get_node_addr(&self) -> Result<NodeAddr>

Get the iroh [NodeAddr] without direct IP addresses.

The address is guaranteed to have home relay URL set as it is the only way to reach the node without global discovery mechanisms.

pub(crate) async fn leave_realtime(&self, topic: TopicId) -> Result<()>

Leave the realtime channel for a given topic.

Trait Implementations

impl Debug for Iroh

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

Formats the value using the given formatter.