Struct Iroh

pub struct Iroh {
    pub(crate) endpoint: Endpoint,
    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

endpoint: Endpoint

[Endpoint] 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_peers( &self, topic: TopicId, peers: Vec<NodeAddr>, ) -> Result<()>

Add gossip peers 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.

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.