Struct LocalFsBackend 

pub struct LocalFsBackend { /* private fields */ }

Local filesystem backend for development and testing.

Implementations

impl LocalFsBackend

pub fn new(config: FileSystemConfig) -> Self

Creates a new LocalFsBackend rooted at the directory in config.

Trait Implementations

impl Backend for LocalFsBackend

fn name(&self) -> &'static str

The backend name, used for diagnostics.

fn put_object<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, metadata: &'life2 Metadata, stream: ClientStream, ) -> Pin<Box<dyn Future<Output = Result<PutResponse>> + Send + 'async_trait>>

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

Stores an object at the given path with the given metadata.

fn get_object<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ObjectId, ) -> Pin<Box<dyn Future<Output = Result<GetResponse>> + Send + 'async_trait>>

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

Retrieves an object at the given path, returning its metadata and a stream of bytes.

fn delete_object<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ObjectId, ) -> Pin<Box<dyn Future<Output = Result<DeleteResponse>> + Send + 'async_trait>>

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

Deletes the object at the given path.

fn get_metadata<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 ObjectId, ) -> Pin<Box<dyn Future<Output = Result<MetadataResponse>> + Send + 'async_trait>>

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

Retrieves only the metadata for an object, without the payload.

fn join<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Waits for any outstanding background operations to complete before shutdown.

impl Debug for LocalFsBackend

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

Formats the value using the given formatter.

impl MultipartUploadBackend for LocalFsBackend

fn initiate_multipart<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, metadata: &'life2 Metadata, ) -> Pin<Box<dyn Future<Output = Result<InitiateMultipartResponse>> + Send + 'async_trait>>

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

Initiates a new multipart upload at id with the given metadata.

fn upload_part<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, id: &'life1 ObjectId, upload_id: &'life2 UploadId, part_number: PartNumber, content_length: u64, _content_md5: Option<&'life3 str>, body: ClientStream, ) -> Pin<Box<dyn Future<Output = Result<UploadPartResponse>> + Send + 'async_trait>>

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

Uploads a single part of the upload identified by (id, upload_id).

fn list_parts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, upload_id: &'life2 UploadId, max_parts: Option<u32>, part_number_marker: Option<PartNumber>, ) -> Pin<Box<dyn Future<Output = Result<ListPartsResponse>> + Send + 'async_trait>>

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

Lists the parts uploaded so far for (id, upload_id).

fn abort_multipart<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, upload_id: &'life2 UploadId, ) -> Pin<Box<dyn Future<Output = Result<AbortMultipartResponse>> + Send + 'async_trait>>

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

Aborts the upload identified by (id, upload_id).

fn complete_multipart<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 ObjectId, upload_id: &'life2 UploadId, parts: Vec<CompletedPart>, ) -> Pin<Box<dyn Future<Output = Result<CompleteMultipartResponse>> + Send + 'async_trait>>

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

Finalizes the upload identified by (id, upload_id) with the given ordered list of parts.