Struct gcs_rsync::storage::ObjectClient [−][src]
pub struct ObjectClient<T> { /* fields omitted */ }Implementations
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>> + '_
Auto Trait Implementations
impl<T> !RefUnwindSafe for ObjectClient<T>
impl<T> Send for ObjectClient<T> where
T: Send,
impl<T> Sync for ObjectClient<T> where
T: Sync,
impl<T> Unpin for ObjectClient<T> where
T: Unpin,
impl<T> !UnwindSafe for ObjectClient<T>
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more