Struct PortableStorage 

pub struct PortableStorage { /* private fields */ }

Clone one cache throughout a browser host. Hydrate before opening its owners; only acknowledge writes after the external storage transaction commits.

Implementations

impl PortableStorage

pub fn new(profile: &str, device: &str) -> Result<PortableStorage, String>

pub fn namespace(&self) -> &ProfileNamespace

pub fn get(&self, key: &StorageKey) -> Option<CachedBytes>

pub fn committed_document_heads( &self, key: &StorageKey, ) -> Option<Result<Vec<ChangeHash>, ()>>

Heads of the exact acknowledged snapshot, never a newer queued value. Reuses canonical save metadata only when the committed bytes match it.

pub fn hydrate( &self, key: StorageKey, bytes: Vec<u8>, actor: Option<Vec<u8>>, ) -> Result<(), String>

Initial durable bytes. Existing entries may never be replaced through hydration.

pub fn put( &self, key: StorageKey, bytes: Vec<u8>, actor: Option<Vec<u8>>, ) -> Result<(), String>

pub fn put_document( &self, key: StorageKey, doc: &mut AutoCommit, actor: Option<Vec<u8>>, ) -> Result<(), String>

Serialize a canonical document and queue its bytes through the ordinary persistence path. Callers cannot supply detached or unverified heads.

pub fn has_pending_writes(&self) -> bool

Whether any value awaits host acknowledgement, without copying the queued values (pending_writes copies every queued document).

pub fn pending_write_sizes(&self) -> Vec<(StorageKey, usize)>

Key and byte length of every queued value, without copying the bytes.

pub fn pending_writes(&self) -> Vec<PendingWrite>

pub fn acknowledge( &self, write: &PendingWrite, result: Result<(), String>, ) -> Result<(), String>

Acknowledging an old revision never makes newer bytes durable.

pub fn status_meta(&self, key: &StorageKey) -> Option<StorageMeta>

Self::status without copying the committed bytes: hot readers (health reports, delivery checks) run several times per frame and the admission journal grows with the session.

pub fn with_committed<R>( &self, key: &StorageKey, read: impl FnOnce(u64, &CachedBytes) -> R, ) -> Option<R>

Borrow the committed value (revision and bytes) without copying it. The closure must not re-enter this storage.

pub fn status(&self, key: &StorageKey) -> Option<StorageStatus>

pub fn flush(&self, key: &StorageKey) -> Result<(), String>

Trait Implementations

impl Clone for PortableStorage

fn clone(&self) -> PortableStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.