Struct Session 

pub struct Session<B: ReplicaStore> {
    pub replica: B,
    /* private fields */
}

Fields

replica: B

Implementations

impl<B: ReplicaStore> Session<B>

pub fn new( replica: B, destination: [u8; 32], facets: BTreeSet<ThreadFacet>, max_items: usize, ) -> Result<Self>

facets is the intersection of authenticated admission scope and the negotiated opening. Local export still checks current sharing policy.

pub async fn export_facets( &self, ) -> StoreResult<BTreeSet<ThreadFacet>, B::Error>

pub async fn announcement(&mut self) -> StoreResult<Option<Frame>, B::Error>

At most one bounded frontier page. Call again until None. A generation change during a paged announcement starts another round, closing gaps.

pub async fn handle( &mut self, frame: Frame, ) -> StoreResult<Vec<Outbound>, B::Error>

pub async fn control(&mut self) -> StoreResult<Option<Frame>, B::Error>

One bounded dependency window, refilled after each received operation. Peer frontiers are durable; outstanding requests are session-local.

pub async fn export_operation( &self, id: ContentHash, ) -> StoreResult<Frame, B::Error>

Resolve payload only when the writer is ready. Pending output queues contain IDs, and policy is checked again immediately before disclosure.

Trait Implementations

impl<B: Clone + ReplicaStore> Clone for Session<B>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.