Struct InsertPayload

pub struct InsertPayload<T> { /* private fields */ }

The payload for object uploads via the Storage client.

The storage client functions to upload new objects consume any type that can be converted to this type. That includes simple buffers, and any type implementing StreamingSource.

Example

use google_cloud_storage::upload_source::StreamingSource;
let buffer : &[u8] = b"the quick brown fox jumps over the lazy dog";
let mut size = 0_usize;
let mut payload = InsertPayload::from(buffer);
while let Some(bytes) = payload.next().await.transpose()? {
    size += bytes.len();
}
assert_eq!(size, buffer.len());

Trait Implementations

impl From<&'static [u8]> for InsertPayload<BytesSource>

fn from(value: &'static [u8]) -> Self

Converts to this type from the input type.

impl From<&'static str> for InsertPayload<BytesSource>

fn from(value: &'static str) -> Self

Converts to this type from the input type.

impl From<Bytes> for InsertPayload<BytesSource>

fn from(value: Bytes) -> Self

Converts to this type from the input type.

impl<S> From<S> for InsertPayload<S>

where S: StreamingSource + Seek,

fn from(value: S) -> Self

Converts to this type from the input type.

impl<T> Seek for InsertPayload<T>

where T: Seek,

type Error = <T as Seek>::Error

The error type.

fn seek( &mut self, offset: u64, ) -> impl Future<Output = Result<(), Self::Error>> + Send

Resets the stream to start from offset.

impl<T> StreamingSource for InsertPayload<T>

where T: StreamingSource,

type Error = <T as StreamingSource>::Error

The error type.

fn next( &mut self, ) -> impl Future<Output = Option<Result<Bytes, Self::Error>>> + Send

Gets the next set of data to upload.

fn size_hint(&self) -> (u64, Option<u64>)

An estimate of the upload size.