Struct laminarmq_io::object_storage::aws_s3::AwsS3BackedFile

pub struct AwsS3BackedFile<P> { /* private fields */ }

Implementations

impl<P> AwsS3BackedFile<P>

where P: for<'a> Deserialize<'a> + PartMap,

pub async fn new( aws_s3_client: Client, bucket: String, object_prefix: String, fallback_part_map: P, ) -> Result<Self, AwsS3Error>

Trait Implementations

impl<P> AsyncAppend for AwsS3BackedFile<P>

where P: PartMap,

async fn append( &mut self, bytes: Bytes, ) -> Result<AppendInfo<Self::Position, Self::Size>, UnwrittenError<Self::Error>>

impl<P> AsyncClose for AwsS3BackedFile<P>

where P: Serialize,

async fn close(self) -> Result<(), Self::Error>

impl<P> AsyncRemove for AwsS3BackedFile<P>

where P: PartMap,

async fn remove(self) -> Result<(), Self::Error>

impl<P> AsyncTruncate for AwsS3BackedFile<P>

where P: PartMap + Serialize,

async fn truncate( &mut self, position: Self::Position, ) -> Result<(), Self::Error>

impl<P> FallibleEntity for AwsS3BackedFile<P>

type Error = AwsS3Error

impl<P> SizedEntity for AwsS3BackedFile<P>

where P: PartMap,

type Position = usize

type Size = usize

fn size(&self) -> Self::Size

fn contains(&self, position: Self::Position) -> bool

impl<P> StreamRead<AwsS3ByteLender> for AwsS3BackedFile<P>

where P: PartMap,

fn read_stream_at<'a>( &'a mut self, position: Self::Position, size: Self::Size, ) -> impl Stream<FallibleByteLender<AwsS3ByteLender, Self::Error>> + 'a

where AwsS3ByteLender: 'a,