Struct HostedReplica 

pub struct HostedReplica<C, A> { /* private fields */ }

Implementations

impl<C: Clock + 'static, A: AcceptedAuthority + Send + Sync + 'static> HostedReplica<C, A>

pub fn with_export_bundle(self, bundle: ImportPublicProofBundleV1) -> Self

Prepared receiver metadata remains bound to the selected authority. Overlay only the public set/proofs; every original byte must agree.

pub fn with_native_export_bundle( self, bundle: NativePublicProofBundleV1, ) -> Self

pub fn with_export_proof(self, bundle: PublicProof) -> Self

pub fn publish_source( &self, source: StagedSource, repository: &Repository, now_seconds: i64, publication: HostedPublication<'_>, response: impl FnOnce(&TrustTransaction<'_>) -> Result<Vec<u8>>, ) -> Result<Vec<u8>, Error>

pub fn authenticate_import_carriers( &self, bundle: &ImportPublicProofBundleV1, now_millis: i64, ) -> Result<VerifiedImportCarriers>

Authenticate import parents for read-only source staging under the receiver’s selected root/history and trusted current time. Publication rechecks the newest durable authority inside its commit transaction.

pub fn recheck_selected( &self, bundle: &ImportPublicProofBundleV1, records: &[SignedRecord], ) -> Result<()>

Recheck retained originals before a source relay. Run this blocking operation on the caller’s storage worker, with its current access gate.

pub fn recheck_native_selected( &self, bundle: &NativePublicProofBundleV1, records: &[SignedRecord], ) -> Result<()>

pub fn recheck_proof( &self, bundle: &PublicProof, records: &[SignedRecord], ) -> Result<()>

Trait Implementations

impl<C, A> Clone for HostedReplica<C, A>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Clock + 'static, A: AcceptedAuthority + Send + Sync + 'static> ReplicaStore for HostedReplica<C, A>

type Error = Error

fn thread_id(&self) -> ContentHash

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

async fn sharing(&self, peer: [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>

Recheck retained hosted authority under the receiver’s mutation serialization before exporting an accepted original. Cached acceptance and structural sidecars grant no authority; keep the complete public evidence attached for the next receiver.

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>