Struct AncestryStore 

pub struct AncestryStore<S, B> { /* private fields */ }

Wraps a record Store and an ancestry BlobStore. On a committed put it also writes the record’s body.bytes() to the ancestry store; because Revision.hash == ContentHash::of(body.bytes()), each version’s body is later retrievable by its revision hash. get/list delegate unchanged.

Implementations

impl<S, B> AncestryStore<S, B>

pub fn new(inner: S, ancestry: B) -> Self

pub fn ancestry(&self) -> &B

The ancestry blob store (revision hash → body bytes), to hand to sync_with_ancestry.

pub fn inner(&self) -> &S

The wrapped record store.

Trait Implementations

impl<S: Store, B: BlobStore> Store for AncestryStore<S, B>

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 RecordKey, ) -> Pin<Box<dyn Future<Output = Result<Option<Record>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch a record by key, or None if absent.

fn put<'life0, 'async_trait>( &'life0 self, record: Record, expected: Option<Revision>, ) -> Pin<Box<dyn Future<Output = Result<PutResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Conditionally write record. expected is the revision the caller believes is current (None means “expect no existing record”). If the store’s current revision differs, returns PutResult::Conflict.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 KeyPrefix, ) -> Pin<Box<dyn Future<Output = Result<Vec<RecordKey>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List keys matching prefix.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 RecordKey, expected: Option<Revision>, ) -> Pin<Box<dyn Future<Output = Result<DeleteResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Conditionally delete the record at key. expected is the revision the caller believes is current: None deletes unconditionally (idempotent no-op if already absent); Some(rev) deletes only if the current revision matches, returning DeleteResult::Conflict if a concurrent write moved it first. Deleting an already-absent key is a no-op Deleted.