Enum ObjectStoreEnum

pub enum ObjectStoreEnum<InMem, Opendal, S3> {
    InMem(InMem),
    Opendal(Opendal),
    S3(S3),
}

Variants

InMem(InMem)

Opendal(Opendal)

S3(S3)

Implementations

impl ObjectStoreEnum<MonitoredStreamingUploader<<InMemObjectStore as ObjectStore>::StreamingUploader>, MonitoredStreamingUploader<<OpendalObjectStore as ObjectStore>::StreamingUploader>, MonitoredStreamingUploader<<S3ObjectStore as ObjectStore>::StreamingUploader>>

pub async fn write_bytes(&mut self, data: Bytes) -> ObjectResult<()>

pub async fn finish(self) -> ObjectResult<()>

pub fn get_memory_usage(&self) -> u64

impl ObjectStoreEnum<MonitoredObjectStore<InMemObjectStore>, MonitoredObjectStore<OpendalObjectStore>, MonitoredObjectStore<S3ObjectStore>>

pub async fn upload(&self, path: &str, obj: Bytes) -> ObjectResult<()>

pub async fn streaming_upload( &self, path: &str, ) -> ObjectResult<ObjectStreamingUploader>

pub async fn read( &self, path: &str, range: impl ObjectRangeBounds, ) -> ObjectResult<Bytes>

pub async fn metadata(&self, path: &str) -> ObjectResult<ObjectMetadata>

pub async fn streaming_read( &self, path: &str, start_loc: Range<usize>, ) -> ObjectResult<MonitoredStreamingReader>

Returns a stream reading the object specified in path. If given, the stream starts at the byte with index start_pos (0-based). As far as possible, the stream only loads the amount of data into memory that is read from the stream.

pub async fn delete(&self, path: &str) -> ObjectResult<()>

pub async fn delete_objects(&self, paths: &[String]) -> ObjectResult<()>

Deletes the objects with the given paths permanently from the storage. If an object specified in the request is not found, it will be considered as successfully deleted.

If a hybrid storage is used, the method will first attempt to delete objects in local storage. Only if that is successful, it will remove objects from remote storage.

pub async fn list( &self, prefix: &str, start_after: Option<String>, limit: Option<usize>, ) -> ObjectResult<ObjectMetadataIter>

pub fn get_object_prefix( &self, obj_id: u64, use_new_object_prefix_strategy: bool, ) -> String

pub fn support_streaming_upload(&self) -> bool

pub fn media_type(&self) -> &'static str