Struct AsyncVersionedMapsTransaction 

pub struct AsyncVersionedMapsTransaction<'tx, 'engine, S>
where
    S: AsyncStore + AsyncManifestStore + AsyncTransactionalStore,
    <S as AsyncStore>::Error: Send + Sync,
    <S as AsyncManifestStore>::Error: Send + Sync,
{ /* private fields */ }

Managed-map facade over one strict async engine transaction.

All staged map heads, immutable version roots, and content-addressed nodes are committed together by the owning super::transaction::AsyncProllyTransaction.

Implementations

impl<'tx, 'engine, S> AsyncVersionedMapsTransaction<'tx, 'engine, S>

where S: AsyncStore + AsyncManifestStore + AsyncTransactionalStore, <S as AsyncStore>::Error: Send + Sync, <S as AsyncManifestStore>::Error: Send + Sync,

pub fn timestamp_millis(&self) -> u64

Timestamp applied to every managed root staged by this transaction.

pub async fn head( &self, map_id: impl AsRef<[u8]>, ) -> Result<Option<MapVersion>, Error>

Load the staged or original head for one map.

pub async fn get( &self, map_id: impl AsRef<[u8]>, key: &[u8], ) -> Result<Option<Vec<u8>>, Error>

Read one key from a staged or original map head.

pub async fn apply( &self, map_id: impl AsRef<[u8]>, mutations: Vec<Mutation>, ) -> Result<MapVersion, Error>

Apply a logical mutation batch to one map inside this transaction.

pub async fn apply_if( &self, map_id: impl AsRef<[u8]>, expected: Option<&MapVersionId>, mutations: Vec<Mutation>, ) -> Result<VersionedMapUpdate, Error>

Conditionally apply mutations when the staged/original head matches.

pub async fn restore_if( &self, map_id: impl AsRef<[u8]>, expected: Option<&MapVersionId>, target: &MapVersionId, ) -> Result<VersionedMapUpdate, Error>

Move one managed map head to a retained immutable version inside the owning strict transaction.

This variant lets callers atomically couple a restore with other managed maps such as audit/commit logs. The target catalog entry is included in the transaction read set and its tree is rehashed before publication.

pub async fn put( &self, map_id: impl AsRef<[u8]>, key: impl Into<Vec<u8>>, value: impl Into<Vec<u8>>, ) -> Result<MapVersion, Error>

Put one key in one managed map.

pub async fn delete( &self, map_id: impl AsRef<[u8]>, key: impl Into<Vec<u8>>, ) -> Result<MapVersion, Error>

Delete one key from one managed map.

pub async fn edit( &self, map_id: impl AsRef<[u8]>, edit: impl FnOnce(&mut VersionedMapEditor), ) -> Result<MapVersion, Error>

Collect and apply several edits to one managed map.