Struct AsyncStorage

pub struct AsyncStorage<B: Backend, S> { /* private fields */ }

Implementations

impl<B: Backend, S> AsyncStorage<B, S>

pub async fn new( config: AsyncStorageInitConfig<B>, ) -> (AsyncStorage<B, S>, AsyncStorageLoop<B, StdIO, S>)

where B: Backend, S: Segment,

pub async fn new_with_io<IO>( config: AsyncStorageInitConfig<B>, io: Arc<IO>, ) -> (AsyncStorage<B, S>, AsyncStorageLoop<B, IO, S>)

where B: Backend, IO: Io, S: Segment,

pub fn backend(&self) -> &B

pub fn send_shutdown(self) -> impl FnOnce()

send shutdown signal to bottomless. return a function that can be called to force shutdown, if necessary

Trait Implementations

impl<B, S> Storage for AsyncStorage<B, S>

where B: Backend, S: Segment,

type Segment = S

type Config = <B as Backend>::Config

async fn shutdown(&self)

fn store( &self, namespace: &NamespaceName, segment: Self::Segment, config_override: Option<Self::Config>, on_store_callback: OnStoreCallback, )

store the passed segment for namespace. This function is called in a context where blocking is acceptable. returns a future that resolves when the segment is stored The segment should be stored whether or not the future is polled.

async fn durable_frame_no( &self, namespace: &NamespaceName, config_override: Option<Self::Config>, ) -> Result<u64>

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

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

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

async fn fetch_segment_data( &self, namespace: &NamespaceName, key: &SegmentKey, config_override: Option<Self::Config>, ) -> Result<CompactedSegment<impl FileExt>>

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