Struct iroh_docs::engine::Engine

pub struct Engine {
    pub endpoint: Endpoint,
    pub sync: SyncHandle,
    pub default_author: Arc<DefaultAuthor>,
    /* private fields */
}

Available on crate feature engine only.

The sync engine coordinates actors that manage open documents, set-reconciliation syncs with peers and a gossip swarm for each syncing document.

Fields

endpoint: Endpoint

[Endpoint] used by the engine.

sync: SyncHandle

Handle to the actor thread.

default_author: Arc<DefaultAuthor>

The persistent default author for this engine.

Implementations

impl Engine

pub async fn spawn<B: Store>( endpoint: Endpoint, gossip: Gossip, replica_store: Store, bao_store: B, downloader: Downloader, default_author_storage: DefaultAuthorStorage ) -> Result<Self>

Start the sync engine.

This will spawn two tokio tasks for the live sync coordination and gossip actors, and a thread for the crate::actor::SyncHandle.

pub async fn start_sync( &self, namespace: NamespaceId, peers: Vec<NodeAddr> ) -> Result<()>

Start to sync a document.

If peers is non-empty, it will both do an initial set-reconciliation sync with each peer, and join an iroh-gossip swarm with these peers to receive and broadcast document updates.

pub async fn leave( &self, namespace: NamespaceId, kill_subscribers: bool ) -> Result<()>

Stop the live sync for a document and leave the gossip swarm.

If kill_subscribers is true, all existing event subscribers will be dropped. This means they will receive None and no further events in case of rejoining the document.

pub async fn subscribe( &self, namespace: NamespaceId ) -> Result<impl Stream<Item = Result<LiveEvent>> + Unpin + 'static>

Subscribe to replica and sync progress events.

pub async fn handle_connection(&self, conn: Connecting) -> Result<()>

Handle an incoming iroh-docs connection.

pub async fn shutdown(&self) -> Result<()>

Shutdown the engine.

Trait Implementations

impl Clone for Engine

fn clone(&self) -> Engine

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Engine

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

Formats the value using the given formatter.

impl ProtocolHandler for Engine

fn accept(self: Arc<Self>, conn: Connecting) -> BoxedFuture<Result<()>>

Handle an incoming connection.

fn shutdown(self: Arc<Self>) -> BoxedFuture<()>

Called when the node shuts down.