Struct LocalReplica 

pub struct LocalReplica<S> { /* private fields */ }

Implementations

impl<S: ObjectStore + Send + Sync + 'static> LocalReplica<S>

pub fn new(replica: ThreadReplica, objects: Arc<S>) -> Self

pub fn with_device_authority(self, home: PathBuf) -> Self

Use independently enrolled local account authority for original metadata authors. Without this binding, new metadata admission fails closed.

Trait Implementations

impl<S> Clone for LocalReplica<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: ObjectStore + Send + Sync + 'static> ReplicaStore for LocalReplica<S>

type Error = Error

fn thread_id(&self) -> ContentHash

async fn generation(&self) -> Result<i64, Error>

async fn sharing( &self, destination: [u8; 32], ) -> Result<BTreeSet<ThreadFacet>, Error>

async fn frontier_page( &self, facet: ThreadFacet, after: Option<ContentHash>, limit: usize, ) -> Result<Vec<ContentHash>, Error>

async fn operation( &self, id: ContentHash, ) -> Result<Option<(ReceivedOperation, Admission)>, Error>

async fn receive(&self, received: ReceivedOperation) -> Result<Admission, Error>

async fn remember_peer_heads( &self, peer: [u8; 32], heads: Vec<(ThreadFacet, ContentHash)>, ) -> Result<(), Error>

async fn record_peer_receipt( &self, peer: [u8; 32], id: ContentHash, admission: Admission, ) -> Result<(), Error>

async fn settled_peer_heads( &self, peer: [u8; 32], facets: BTreeSet<ThreadFacet>, limit: usize, ) -> Result<Vec<(ContentHash, Admission)>, Error>

async fn needed_from_peer( &self, peer: [u8; 32], facets: BTreeSet<ThreadFacet>, limit: usize, ) -> Result<Vec<ContentHash>, Error>