Struct Engine

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

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: DefaultAuthor

The persistent default author for this engine.

Implementations

impl Engine

pub async fn spawn( endpoint: Endpoint, gossip: Gossip, replica_store: Store, bao_store: Store, downloader: Downloader, default_author_storage: DefaultAuthorStorage, protect_cb: Option<ProtectCallbackHandler>, ) -> 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 actor interacting with doc storage.

pub fn blob_store(&self) -> &Store

Get the blob store.

pub fn metrics(&self) -> &Arc<Metrics>

Returns the metrics tracked for this engine.

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: Connection) -> Result<()>

Handle an incoming iroh-docs connection.

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

Shutdown the engine.

Trait Implementations

impl Debug for Engine

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

Formats the value using the given formatter.