Struct gcs_rsync::storage::ObjectClient

pub struct ObjectClient { /* private fields */ }

Implementations

impl ObjectClient

pub async fn new(
    token_generator: Box<dyn TokenGenerator>
) -> StorageResult<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 list(
    &self,
    bucket: &str,
    objects_list_request: &ObjectsListRequest
) -> impl Stream<Item = StorageResult<PartialObject>> + '_