Struct iroh_sync::actor::SyncHandle

pub struct SyncHandle { /* private fields */ }

The SyncHandle is the handle to a thread that runs replica and store operations.

Implementations

impl SyncHandle

pub fn spawn<S: Store>( store: S, content_status_callback: Option<ContentStatusCallback>, me: String ) -> SyncHandle

Spawn a sync actor and return a handle.

pub async fn open(&self, namespace: NamespaceId, opts: OpenOpts) -> Result<()>

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

pub async fn subscribe( &self, namespace: NamespaceId, sender: Sender<Event> ) -> Result<()>

pub async fn unsubscribe( &self, namespace: NamespaceId, sender: Sender<Event> ) -> Result<()>

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

pub async fn insert_local( &self, namespace: NamespaceId, author: AuthorId, key: Bytes, hash: Hash, len: u64 ) -> Result<()>

pub async fn delete_prefix( &self, namespace: NamespaceId, author: AuthorId, key: Bytes ) -> Result<usize>

pub async fn insert_remote( &self, namespace: NamespaceId, entry: SignedEntry, from: PeerIdBytes, content_status: ContentStatus ) -> Result<()>

pub async fn sync_initial_message( &self, namespace: NamespaceId ) -> Result<Message<SignedEntry>>

pub async fn sync_process_message( &self, namespace: NamespaceId, message: Message<SignedEntry>, from: PeerIdBytes, state: SyncOutcome ) -> Result<(Option<Message<SignedEntry>>, SyncOutcome)>

pub async fn get_sync_peers( &self, namespace: NamespaceId ) -> Result<Option<Vec<PeerIdBytes>>>

pub async fn register_useful_peer( &self, namespace: NamespaceId, peer: PeerIdBytes ) -> Result<()>

pub async fn has_news_for_us( &self, namespace: NamespaceId, heads: AuthorHeads ) -> Result<Option<NonZeroU64>>

pub async fn get_many( &self, namespace: NamespaceId, filter: GetFilter, reply: Sender<Result<SignedEntry>> ) -> Result<()>

pub async fn get_one( &self, namespace: NamespaceId, author: AuthorId, key: Bytes ) -> Result<Option<SignedEntry>>

pub async fn drop_replica(&self, namespace: NamespaceId) -> Result<()>

pub async fn export_secret_key( &self, namespace: NamespaceId ) -> Result<Namespace>

pub async fn get_state(&self, namespace: NamespaceId) -> Result<OpenState>

pub async fn shutdown(&self)

pub async fn list_authors(&self, reply: Sender<Result<AuthorId>>) -> Result<()>

pub async fn list_replicas( &self, reply: Sender<Result<NamespaceId>> ) -> Result<()>

pub async fn import_author(&self, author: Author) -> Result<AuthorId>

pub async fn import_namespace( &self, namespace: Namespace ) -> Result<NamespaceId>

Trait Implementations

impl Clone for SyncHandle

fn clone(&self) -> SyncHandle

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SyncHandle

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

Formats the value using the given formatter.