Struct ObjectStoreRemote 

pub struct ObjectStoreRemote { /* 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 ObjectStoreRemote

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

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

Trait Implementations

impl BlobStore for ObjectStoreRemote

type Reader = ObjectStoreReader

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 BlobStoreForget for ObjectStoreRemote

type ForgetError = Error

Error type for forget operations.

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

where S: BlobEncoding + 'static, Handle<S>: InlineEncoding,

Removes the materialized blob identified by handle from this store.

impl BlobStorePut for ObjectStoreRemote

type PutError = Error

Error type for put operations.

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

where S: BlobEncoding + 'static, T: IntoBlob<S>, Handle<S>: InlineEncoding,

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

impl Debug for ObjectStoreRemote

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

Formats the value using the given formatter.

impl PinStore for ObjectStoreRemote

type PinsError = ListBranchesErr

Error type for listing pins.

type HeadError = PullBranchErr

Error type for head lookups.

type UpdateError = PushBranchErr

Error type for CAS updates.

type ListIter<'a> = BlockingIter<Result<Id, <ObjectStoreRemote as PinStore>::PinsError>>

Iterator over pin IDs.

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

Lists every pin in the store. Returns a fallible iterator over pin ids (any role — branches, tracking pins, local-only pins). Callers that want only content branches filter by checking for the metadata::name attribute on each pin’s head metadata.

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

Retrieves the current head of a pin by its id.

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

Compare-and-swap update of a pin’s head.

fn pin_snapshot(&mut self) -> Result<PinSnapshot, Self::PinsError>

Cheap point-in-time snapshot of the (pin id → head) map.

impl StorageClose for ObjectStoreRemote

type Error = Infallible

Error type returned by close.

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

Consume the storage and perform any necessary cleanup.