Struct bonsaidb::keystorage::s3::aws_sdk_s3::primitives::SdkBody
pub struct SdkBody { /* private fields */ }Expand description
SdkBody type
This is the Body used for dispatching all HTTP Requests. For handling responses, the type of the body will be controlled by the HTTP stack.
Implementations§
§impl SdkBody
impl SdkBody
pub fn from_dyn(body: BoxBody<Bytes, Box<dyn Error + Send + Sync>>) -> SdkBody
pub fn from_dyn(body: BoxBody<Bytes, Box<dyn Error + Send + Sync>>) -> SdkBody
Construct an SdkBody from a Boxed implementation of http::Body
pub fn retryable(f: impl Fn() -> SdkBody + Send + Sync + 'static) -> SdkBody
pub fn retryable(f: impl Fn() -> SdkBody + Send + Sync + 'static) -> SdkBody
Construct an explicitly retryable SDK body
Note: This is probably not what you want
All bodies constructed from in-memory data (String, Vec<u8>, Bytes, etc.) will be
retryable out of the box. If you want to read data from a file, you should use
ByteStream::from_path. This function
is only necessary when you need to enable retries for your own streaming container.
pub fn taken() -> SdkBody
pub fn taken() -> SdkBody
When an SdkBody is read, the inner data must be consumed. In order to do this, the SdkBody is swapped with a “taken” body. This “taken” body cannot be read but aids in debugging.
pub fn empty() -> SdkBody
pub fn empty() -> SdkBody
Create an empty SdkBody for requests and responses that don’t transfer any data in the body.
pub fn bytes(&self) -> Option<&[u8]>
pub fn bytes(&self) -> Option<&[u8]>
If possible, return a reference to this body as &[u8]
If this SdkBody is NOT streaming, this will return the byte slab
If this SdkBody is streaming, this will return None
pub fn try_clone(&self) -> Option<SdkBody>
pub fn try_clone(&self) -> Option<SdkBody>
Attempt to clone this SdkBody. This will fail if the inner data is not cloneable, such as when it is a single-use stream that can’t be recreated.
pub fn content_length(&self) -> Option<u64>
pub fn content_length(&self) -> Option<u64>
Return the length, in bytes, of this SdkBody. If this returns None, then the body does not
have a known length.
Trait Implementations§
§impl Body for SdkBody
impl Body for SdkBody
§fn poll_data(
self: Pin<&mut SdkBody>,
cx: &mut Context<'_>
) -> Poll<Option<Result<<SdkBody as Body>::Data, <SdkBody as Body>::Error>>>
fn poll_data( self: Pin<&mut SdkBody>, cx: &mut Context<'_> ) -> Poll<Option<Result<<SdkBody as Body>::Data, <SdkBody as Body>::Error>>>
§fn poll_trailers(
self: Pin<&mut SdkBody>,
_cx: &mut Context<'_>
) -> Poll<Result<Option<HeaderMap>, <SdkBody as Body>::Error>>
fn poll_trailers( self: Pin<&mut SdkBody>, _cx: &mut Context<'_> ) -> Poll<Result<Option<HeaderMap>, <SdkBody as Body>::Error>>
HeaderMap of trailers. Read more§fn is_end_stream(&self) -> bool
fn is_end_stream(&self) -> bool
true when the end of stream has been reached. Read moresource§fn trailers(&mut self) -> Trailers<'_, Self>
fn trailers(&mut self) -> Trailers<'_, Self>
source§fn map_data<F, B>(self, f: F) -> MapData<Self, F>
fn map_data<F, B>(self, f: F) -> MapData<Self, F>
source§fn map_err<F, E>(self, f: F) -> MapErr<Self, F>
fn map_err<F, E>(self, f: F) -> MapErr<Self, F>
source§fn collect(self) -> Collect<Self>where
Self: Sized,
fn collect(self) -> Collect<Self>where
Self: Sized,
Collected body which will collect all the DATA frames
and trailers.