Struct Store 

pub struct Store<T> { /* private fields */ }

Versioned recording objects on a generic ObjectStore.

Implementations

impl<T: ObjectStore> Store<T>

pub fn new(inner: T, prefix: impl Into<Path>) -> Self

Wrap inner with an application-defined recording prefix.

pub fn inner(&self) -> &T

The underlying object store.

pub fn prefix(&self) -> &Path

The recording prefix.

pub fn path(&self, key: &Key) -> Result<Path>

Encode key under this store’s prefix.

pub async fn put_info(&self, track: &str, info: &Info) -> Result<Key>

Create .info, or accept an existing object with the same parsed properties.

pub async fn get_info(&self, track: &str) -> Result<Info>

Fetch and validate a track’s .info.

pub async fn put_groups(&self, track: &str, object: &Object) -> Result<Key>

Create a range-named groups object. A collision is accepted only when the bytes match.

pub async fn get_groups( &self, track: &str, range: RangeInclusive<u64>, ) -> Result<Object>

Fetch a groups object and require its table to match the filename bounds.

pub async fn put_segments( &self, track: &str, segment: u64, object: &Object, ) -> Result<Key>

Create a timeline object at segments/<segment>. A collision is accepted only when the bytes match.

pub async fn get_segments(&self, track: &str, segment: u64) -> Result<Object>

Fetch and validate a timeline object.

pub async fn delete(&self, key: &Key) -> Result<()>

Delete the object at key.

pub fn list(&self, query: &Query) -> BoxStream<'static, Result<Entry>>

Stream matching entries. Order is unspecified and max_keys is ignored. Continuation queries from Page::next fail; pass them to list_paginated.

impl<T: ObjectStore + PaginatedListStore> Store<T>

pub async fn list_paginated(&self, query: &Query) -> Result<Page>

List one page while keeping the backend continuation token inside the returned query.

Trait Implementations

impl<T: Clone> Clone for Store<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Store<T>

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

Formats the value using the given formatter.