Struct IrohTransport 

pub struct IrohTransport { /* private fields */ }

Iroh transport implementation using QUIC peer-to-peer networking.

Provides NAT traversal and direct peer-to-peer connectivity using the Iroh protocol. Supports both relay-assisted and direct connections.

How It Works

1. Discovery: Peers find each other via relay servers or direct addresses
2. Connection: Attempts direct connection through NAT hole-punching
3. Fallback: Uses relay servers if direct connection fails
4. Upgrade: Automatically upgrades to direct connection when possible

Server Addresses

Addresses use iroh’s standard EndpointTicket format (postcard + base32-lower with endpoint prefix) for both get_server_address() and DatabaseTicket URLs.

Example

use eidetica::sync::transports::iroh::IrohTransport;
use iroh::RelayMode;

// Create with defaults (production relay servers)
let transport = IrohTransport::new()?;

// Or use the builder for custom configuration
let transport = IrohTransport::builder()
    .relay_mode(RelayMode::Staging)
    .build()?;

Implementations

impl IrohTransport

pub const TRANSPORT_TYPE: &'static str = "iroh"

Transport type identifier for Iroh

pub fn new() -> Result<Self>

Create a new Iroh transport instance with production defaults.

Uses RelayMode::Default which connects to n0’s production relay infrastructure. For custom configuration, use IrohTransport::builder().

The endpoint will be lazily initialized on first use.

Example

use eidetica::sync::transports::iroh::IrohTransport;

let transport = IrohTransport::new()?;
// Use with: sync.enable_iroh_transport_with_config(transport)?;

pub fn builder() -> IrohTransportBuilder

Create a builder for configuring the transport.

Allows customization of relay modes and other transport options.

Example

use eidetica::sync::transports::iroh::IrohTransport;
use iroh::RelayMode;

let transport = IrohTransport::builder()
    .relay_mode(RelayMode::Disabled)
    .build()?;

Trait Implementations

impl SyncTransport for IrohTransport

fn transport_type(&self) -> &'static str

Get the transport type identifier.

fn can_handle_address(&self, address: &Address) -> bool

Check if this transport can handle the given address

fn start_server<'life0, 'async_trait>( &'life0 mut self, handler: Arc<dyn SyncHandler>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Start a server with the pre-configured bind address.

fn stop_server<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stop the running server gracefully.

fn send_request<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, address: &'life1 Address, request: &'life2 SyncRequest, ) -> Pin<Box<dyn Future<Output = Result<SyncResponse>> + Send + 'async_trait>>

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

Send a sync request to a peer and receive a response.

fn is_server_running(&self) -> bool

Check if the server is currently running.

fn get_server_address(&self) -> Result<String>

Get the address the server is currently bound to.

fn send_entries<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, address: &'life1 Address, entries: &'life2 [Entry], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Send entries to a sync peer and ensure they are acknowledged.