Struct RemoteProllyStore 

pub struct RemoteProllyStore<B> { /* private fields */ }

Generic adapter over a remote backend.

Implementations

impl<B> RemoteProllyStore<B>

pub fn new(backend: B) -> RemoteProllyStore<B>

Create an adapter with default configuration.

pub fn with_config( backend: B, config: RemoteStoreConfig, ) -> RemoteProllyStore<B>

Create an adapter with explicit configuration.

pub fn backend(&self) -> &B

Borrow the backend.

pub fn into_backend(self) -> B

Consume the adapter and return the backend.

Trait Implementations

impl<B> AsyncManifestStore for RemoteProllyStore<B>

where B: RemoteStoreBackend,

type Error = RemoteAdapterError<<B as RemoteStoreBackend>::Error>

Error type for manifest operations.

async fn get_root( &self, name: &[u8], ) -> Result<Option<RootManifest>, <RemoteProllyStore<B> as AsyncManifestStore>::Error>

Load a named root manifest.

async fn put_root( &self, name: &[u8], manifest: &RootManifest, ) -> Result<(), <RemoteProllyStore<B> as AsyncManifestStore>::Error>

Unconditionally insert or replace a named root manifest.

async fn delete_root( &self, name: &[u8], ) -> Result<(), <RemoteProllyStore<B> as AsyncManifestStore>::Error>

Delete a named root manifest. Deleting a missing name is not an error.

async fn compare_and_swap_root( &self, name: &[u8], expected: Option<&RootManifest>, new: Option<&RootManifest>, ) -> Result<ManifestUpdate, <RemoteProllyStore<B> as AsyncManifestStore>::Error>

Atomically update a named root if the current manifest matches expected.

impl<B> AsyncManifestStoreScan for RemoteProllyStore<B>

where B: RemoteStoreBackend,

async fn list_roots( &self, ) -> Result<Vec<NamedRootManifest>, <RemoteProllyStore<B> as AsyncManifestStore>::Error>

List all durable named root manifests.

impl<B> AsyncStore for RemoteProllyStore<B>

where B: RemoteStoreBackend,

type Error = RemoteAdapterError<<B as RemoteStoreBackend>::Error>

Error type for storage operations.

async fn get( &self, key: &[u8], ) -> Result<Option<Vec<u8>>, <RemoteProllyStore<B> as AsyncStore>::Error>

Get value by key.

async fn put( &self, key: &[u8], value: &[u8], ) -> Result<(), <RemoteProllyStore<B> as AsyncStore>::Error>

Store key-value pair.

async fn delete( &self, key: &[u8], ) -> Result<(), <RemoteProllyStore<B> as AsyncStore>::Error>

Delete key.

async fn batch( &self, ops: &[BatchOp<'_>], ) -> Result<(), <RemoteProllyStore<B> as AsyncStore>::Error>

Batch write operations.

async fn batch_get_ordered( &self, keys: &[&[u8]], ) -> Result<Vec<Option<Vec<u8>>>, <RemoteProllyStore<B> as AsyncStore>::Error>

Retrieve multiple keys while preserving request order.

async fn batch_get_ordered_unique( &self, keys: &[&[u8]], ) -> Result<Vec<Option<Vec<u8>>>, <RemoteProllyStore<B> as AsyncStore>::Error>

Retrieve unique keys in request order.

fn prefers_batch_reads(&self) -> bool

Whether this store has an efficient native batched-read implementation.

fn read_parallelism(&self) -> usize

Maximum in-flight point reads for default ordered batch reads.

async fn batch_put( &self, entries: &[(&[u8], &[u8])], ) -> Result<(), <RemoteProllyStore<B> as AsyncStore>::Error>

Store multiple key-value pairs.

fn supports_hints(&self) -> bool

Whether this store persists performance hints.

fn prefers_rightmost_path_hints(&self) -> bool

Whether append-heavy writes should maintain the engine’s rightmost-path hint.

async fn get_hint( &self, namespace: &[u8], key: &[u8], ) -> Result<Option<Vec<u8>>, <RemoteProllyStore<B> as AsyncStore>::Error>

Retrieve an optional performance hint.

async fn put_hint( &self, namespace: &[u8], key: &[u8], value: &[u8], ) -> Result<(), <RemoteProllyStore<B> as AsyncStore>::Error>

Persist an optional performance hint.

async fn batch_put_with_hint( &self, entries: &[(&[u8], &[u8])], namespace: &[u8], key: &[u8], value: &[u8], ) -> Result<(), <RemoteProllyStore<B> as AsyncStore>::Error>

Store content-addressed nodes and one hint atomically when supported.

async fn publish_nodes( &self, publication: NodePublication<'_>, ) -> Result<(), <RemoteProllyStore<B> as AsyncStore>::Error>

Publish canonical immutable nodes with advisory logical context.

async fn get_shared(&self, key: &[u8]) -> Result<Option<Arc<[u8]>>, Self::Error>

Async immutable shared-byte read.

async fn batch_get_shared_ordered_unique( &self, keys: &[&[u8]], ) -> Result<Vec<Option<Arc<[u8]>>>, Self::Error>

Async ordered retained-byte batch read for unique keys.

fn has_native_shared_reads(&self) -> bool

Whether async shared reads retain backend-owned immutable allocations.

async fn batch_get( &self, keys: &[&[u8]], ) -> Result<HashMap<Vec<u8>, Vec<u8>>, Self::Error>

Retrieve multiple keys as a map.

impl<B> AsyncTransactionalStore for RemoteProllyStore<B>

where B: RemoteStoreBackend,

fn supports_transactions(&self) -> bool

Whether this backend can atomically commit staged nodes and roots.

async fn commit_transaction( &self, node_writes: &[TransactionNodeWrite], root_conditions: &[RootCondition], root_writes: &[RootWrite], ) -> Result<TransactionUpdate, Error>

Atomically validate root conditions, write nodes, and apply root writes.

impl<B> Clone for RemoteProllyStore<B>

where B: Clone,

fn clone(&self) -> RemoteProllyStore<B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B> Debug for RemoteProllyStore<B>

where B: Debug,

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

Formats the value using the given formatter.