Struct IrohFileDistribution 

pub struct IrohFileDistribution { /* private fields */ }

Iroh-based file distribution service

Distributes files/models using NetworkedIrohBlobStore with:

• Blob tokens stored in Automerge documents for discovery
• Direct P2P transfer via iroh-blobs protocol
• Status tracking via distribution documents

Architecture

IrohFileDistribution
    ├─ NetworkedIrohBlobStore (P2P blob transfer)
    └─ AutomergeStore (distribution metadata sync)

Distribution Flow:
1. Commander calls distribute(token, scope)
2. Distribution document created in Automerge with blob token
3. Document syncs to target nodes via CRDT sync
4. Target nodes see distribution doc, fetch blob via iroh-blobs
5. Target nodes update their status in distribution doc

Implementations

impl IrohFileDistribution

pub fn new( blob_store: Arc<NetworkedIrohBlobStore>, document_store: Arc<AutomergeStore>, ) -> Self

Create a new Iroh file distribution service

pub fn blob_store(&self) -> &Arc<NetworkedIrohBlobStore>

Get the blob store reference

pub fn document_store(&self) -> &Arc<AutomergeStore>

Get the document store reference

Trait Implementations

impl FileDistribution for IrohFileDistribution

fn distribute<'life0, 'life1, 'async_trait>( &'life0 self, blob_token: &'life1 BlobToken, scope: DistributionScope, priority: TransferPriority, ) -> Pin<Box<dyn Future<Output = Result<DistributionHandle>> + Send + 'async_trait>>

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

Distribute blob to target nodes

fn status<'life0, 'life1, 'async_trait>( &'life0 self, handle: &'life1 DistributionHandle, ) -> Pin<Box<dyn Future<Output = Result<DistributionStatus>> + Send + 'async_trait>>

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

Get current distribution status

fn cancel<'life0, 'life1, 'async_trait>( &'life0 self, handle: &'life1 DistributionHandle, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Cancel an in-progress distribution

fn wait_for_completion<'life0, 'life1, 'async_trait>( &'life0 self, handle: &'life1 DistributionHandle, timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<DistributionStatus>> + Send + 'async_trait>>

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

Wait for distribution to complete (or fail)

fn subscribe_progress<'life0, 'life1, 'async_trait>( &'life0 self, handle: &'life1 DistributionHandle, ) -> Pin<Box<dyn Future<Output = Result<Receiver<DistributionStatus>>> + Send + 'async_trait>>

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

Subscribe to distribution progress updates