Struct ObjectClient 

pub struct ObjectClient { /* private fields */ }

Implementations

impl ObjectClient

pub async fn new( token_generator: Box<dyn TokenGenerator>, ) -> StorageResult<Self>

pub fn no_auth() -> Self

pub async fn get( &self, o: &Object, fields: &str, ) -> StorageResult<PartialObject>

pub async fn delete(&self, o: &Object) -> StorageResult<String>

pub async fn download( &self, o: &Object, ) -> StorageResult<impl Stream<Item = StorageResult<Bytes>>>

pub async fn upload<S>(&self, o: &Object, stream: S) -> StorageResult<()>

where S: TryStream + Send + Sync + 'static, S::Error: Into<Box<dyn Error + Send + Sync>>, Bytes: From<S::Ok>,

pub async fn upload_with_metadata<S>( &self, m: &ObjectMetadata, o: &Object, stream: S, ) -> StorageResult<()>

where S: TryStream<Ok = Bytes> + Send + Sync + 'static, S::Error: Into<Box<dyn Error + Send + Sync>> + Send + Sync,

pub async fn is_valid(&self, bucket: &str, prefix: &str) -> StorageResult<()>

pub async fn list( &self, bucket: &str, objects_list_request: &ObjectsListRequest, ) -> impl Stream<Item = StorageResult<PartialObject>> + '_