Struct ObjectStoreRemote 

pub struct ObjectStoreRemote<H> { /* private fields */ }

Repository backed by an object_store compatible storage backend.

All data is stored in an external service (e.g. S3, local filesystem) via the object_store crate.

Implementations

impl<H> ObjectStoreRemote<H>

pub fn with_url(url: &Url) -> Result<ObjectStoreRemote<H>, Error>

Creates a repository pointing at the object store described by url.

Trait Implementations

impl<H> BlobStore<H> for ObjectStoreRemote<H>

where H: HashProtocol,

type Reader = ObjectStoreReader<H>

A clonable reader handle for concurrent blob lookups.

type ReaderError = Infallible

Error type for creating a reader.

fn reader(&mut self) -> Result<Self::Reader, Self::ReaderError>

Creates a shareable reader snapshot of the current store state.

impl<H> BlobStoreForget<H> for ObjectStoreRemote<H>

where H: HashProtocol,

type ForgetError = Error

Error type for forget operations.

fn forget<S>( &mut self, handle: Value<Handle<H, S>>, ) -> Result<(), Self::ForgetError>

where S: BlobSchema + 'static, Handle<H, S>: ValueSchema,

Removes the materialized blob identified by handle from this store.

impl<H> BlobStorePut<H> for ObjectStoreRemote<H>

where H: HashProtocol,

type PutError = Error

Error type for put operations.

fn put<S, T>(&mut self, item: T) -> Result<Value<Handle<H, S>>, Self::PutError>

where S: BlobSchema + 'static, T: ToBlob<S>, Handle<H, S>: ValueSchema,

Serialises item as a blob, stores it, and returns its handle.

impl<H> BranchStore<H> for ObjectStoreRemote<H>

where H: HashProtocol,

type BranchesError = ListBranchesErr

Error type for listing branches.

type HeadError = PullBranchErr

Error type for head lookups.

type UpdateError = PushBranchErr

Error type for CAS updates.

type ListIter<'a> = BlockingIter<Result<Id, <ObjectStoreRemote<H> as BranchStore<H>>::BranchesError>>

Iterator over branch IDs.

fn branches<'a>(&'a mut self) -> Result<Self::ListIter<'a>, Self::BranchesError>

Lists all branches in the repository. This function returns a stream of branch ids.

fn head( &mut self, id: Id, ) -> Result<Option<Value<Handle<H, SimpleArchive>>>, Self::HeadError>

Retrieves a branch from the repository by its id. The id is a unique identifier for the branch, and is used to retrieve it from the repository.

fn update( &mut self, id: Id, old: Option<Value<Handle<H, SimpleArchive>>>, new: Option<Value<Handle<H, SimpleArchive>>>, ) -> Result<PushResult<H>, Self::UpdateError>

Puts a branch on the repository, creating or updating it.

impl<H> Debug for ObjectStoreRemote<H>

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

Formats the value using the given formatter.

impl<H> StorageClose for ObjectStoreRemote<H>

type Error = Infallible

Error type returned by close.

fn close(self) -> Result<(), Self::Error>

Consume the storage and perform any necessary cleanup.