Enum ServerObjectStore 

pub enum ServerObjectStore {
    Local(LocalObjectStore),
    S3(S3ObjectStore),
    Blackhole,
}

Unified object-store backend that delegates to local, S3, or blackhole storage.

Variants

Local(LocalObjectStore)

Local filesystem object store.

S3(S3ObjectStore)

S3-compatible object store.

Blackhole

Blackhole object store that discards all writes.

Implementations

impl ServerObjectStore

pub fn local( root: impl Into<PathBuf>, ) -> Result<ServerObjectStore, ServerObjectStoreError>

Creates a local filesystem object store rooted at the given path.

Errors

Returns ServerObjectStoreError::Local if the local store cannot be created.

pub fn s3( config: S3ObjectStoreConfig, ) -> Result<ServerObjectStore, ServerObjectStoreError>

Creates an S3-compatible object store from the provided configuration.

Errors

Returns ServerObjectStoreError::S3 if the S3 store cannot be created.

pub const fn blackhole() -> ServerObjectStore

Creates a blackhole object store that discards all writes.

pub fn put_overwrite( &self, key: &ObjectKey, body: ObjectBody<'_>, integrity: &ObjectIntegrity, ) -> Result<(), ServerObjectStoreError>

Stores an object, overwriting any existing object at the given key.

Errors

Returns ServerObjectStoreError on storage backend failures.

pub fn visit_prefix<F, E>( &self, prefix: &ObjectPrefix, visitor: F, ) -> Result<(), E>

where F: FnMut(ObjectMetadata) -> Result<(), E>, E: From<LocalObjectStoreError> + From<S3ObjectStoreError>,

Visits all objects under the given prefix, invoking the visitor for each.

Errors

Returns any error produced by the visitor or the underlying storage backend.

pub fn list_flat_namespace_page( &self, prefix: &ObjectPrefix, start_after: Option<&ObjectKey>, limit: usize, ) -> Result<Vec<ObjectMetadata>, ServerObjectStoreError>

Lists objects under the given prefix with pagination.

Errors

Returns ServerObjectStoreError on storage backend failures.

pub fn local_path_for_key(&self, key: &ObjectKey) -> Option<PathBuf>

Returns the local filesystem path for an object key, if backed by local storage.

pub fn copy_if_absent( &self, source: &ObjectKey, destination: &ObjectKey, ) -> Result<PutOutcome, ServerObjectStoreError>

Copies an object from source to destination if no object exists at the destination.

Errors

Returns ServerObjectStoreError::NotFound for blackhole stores or storage backend errors.

pub fn put_content_addressed_file( &self, key: &ObjectKey, path: &Path, integrity: &ObjectIntegrity, ) -> Result<PutOutcome, ServerObjectStoreError>

Stores a content-addressed file from the local filesystem.

Errors

Returns ServerObjectStoreError on storage backend failures.

pub fn local_root(&self) -> Option<&Path>

Returns the local filesystem root, if backed by local storage.

pub const fn backend_name(&self) -> &'static str

Returns the backend name for this object store.

pub fn read_full_object( &self, object_key: &ObjectKey, length: u64, ) -> Result<Vec<u8>, ServerObjectStoreError>

Reads the full contents of an object from the store.

Errors

Returns ServerObjectStoreError on storage backend failures, length mismatches, or arithmetic overflows.

Trait Implementations

impl Clone for ServerObjectStore

fn clone(&self) -> ServerObjectStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServerObjectStore

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

Formats the value using the given formatter.

impl ObjectStore for ServerObjectStore

type Error = ServerObjectStoreError

Adapter-specific error type.

fn put_if_absent( &self, key: &ObjectKey, body: ObjectBody<'_>, integrity: &ObjectIntegrity, ) -> Result<PutOutcome, <ServerObjectStore as ObjectStore>::Error>

Stores an object if no identical object exists yet.

fn read_range( &self, key: &ObjectKey, range: ByteRange, ) -> Result<Vec<u8>, <ServerObjectStore as ObjectStore>::Error>

Reads an inclusive byte range from an object.

fn contains( &self, key: &ObjectKey, ) -> Result<bool, <ServerObjectStore as ObjectStore>::Error>

Returns whether an object exists.

fn metadata( &self, key: &ObjectKey, ) -> Result<Option<ObjectMetadata>, <ServerObjectStore as ObjectStore>::Error>

Returns stored metadata for an object.

fn list_prefix( &self, prefix: &ObjectPrefix, ) -> Result<Vec<ObjectMetadata>, <ServerObjectStore as ObjectStore>::Error>

Lists objects under a validated key prefix.

fn delete_if_present( &self, key: &ObjectKey, ) -> Result<DeleteOutcome, <ServerObjectStore as ObjectStore>::Error>

Deletes an object if it exists.

fn visit_prefix<Visitor, VisitorError>( &self, prefix: &ObjectPrefix, visitor: Visitor, ) -> Result<(), VisitorError>

where Self::Error: Into<VisitorError>, Visitor: FnMut(ObjectMetadata) -> Result<(), VisitorError>,

Visits objects under a validated key prefix without requiring callers to own the full inventory at once.