Struct S3Backend

pub struct S3Backend<IO> { /* private fields */ }

Implementations

impl S3Backend<StdIO>

pub async fn from_sdk_config( aws_config: SdkConfig, bucket: String, cluster_id: String, ) -> Result<S3Backend<StdIO>>

Trait Implementations

impl<IO> Backend for S3Backend<IO>

where IO: Io,

type Config = Arc<S3Config>

Config type associated with the Storage

async fn store( &self, config: &Self::Config, meta: SegmentMeta, segment_data: impl FileExt, segment_index: Vec<u8>, ) -> Result<()>

Store segment_data with its associated meta

async fn meta( &self, config: &Self::Config, namespace: &NamespaceName, ) -> Result<DbMeta>

Fetch meta for namespace

fn default_config(&self) -> Self::Config

Returns the default configuration for this storage

async fn restore( &self, config: &Self::Config, namespace: &NamespaceName, restore_options: RestoreOptions, dest: impl FileExt, ) -> Result<()>

async fn find_segment( &self, config: &Self::Config, namespace: &NamespaceName, req: FindSegmentReq, ) -> Result<SegmentKey>

async fn fetch_segment_index( &self, config: &Self::Config, namespace: &NamespaceName, key: &SegmentKey, ) -> Result<Map<Arc<[u8]>>>

async fn fetch_segment_data_to_file( &self, config: &Self::Config, namespace: &NamespaceName, key: &SegmentKey, file: &impl FileExt, ) -> Result<CompactedSegmentDataHeader>

Fetch a segment for namespace containing frame_no, and writes it to dest.

async fn fetch_segment_data( self: Arc<Self>, config: Self::Config, namespace: NamespaceName, key: SegmentKey, ) -> Result<impl FileExt>

fn list_segments<'a>( &'a self, config: Self::Config, namespace: &'a NamespaceName, until: u64, ) -> impl Stream<Item = Result<SegmentInfo>> + 'a