Struct ObjectStoreIo 

pub(crate) struct ObjectStoreIo {
    store: ObjectStore,
    object_prefix: String,
}

Reads and writes the WAL objects under one prefix.

Fields

store: ObjectStore

object_prefix: String

Implementations

impl ObjectStoreIo

pub(crate) fn new(store: ObjectStore, prefix: impl AsRef<str>) -> Result<Self>

Binds store to the objects under prefix. The store must support conditional creates, which is what keeps a retried write from overwriting a durable object.

pub(crate) async fn put_if_absent( &self, object_seq: u64, content: Bytes, ) -> Result<PutResult>

Creates the object object_seq unless it already exists. A retry with the same content is accepted, different content is rejected.

When the store reports that the object exists but the read that compares its content fails, the read failure is returned, so that its retry hint says whether comparing again may settle the outcome. Any other create failure is returned as the write failure it is.

pub(crate) async fn get(&self, object_seq: u64) -> Result<Bytes>

Reads the object object_seq.

pub(crate) async fn get_range( &self, object_seq: u64, offset: u64, len: u64, ) -> Result<Bytes>

Reads len bytes of the object object_seq starting at offset. The range must lie inside the object; one that reaches past its end fails.

pub(crate) async fn list(&self) -> Result<Vec<ListedObject>>

Lists the objects under the prefix, ordered by object sequence. Keys that do not follow the object layout are ignored.

pub(crate) fn object_path(&self, object_seq: u64) -> String

fn parse_object_seq(&self, path: &str) -> Option<u64>

Trait Implementations

impl WalObjectIo for ObjectStoreIo

fn put_if_absent<'life0, 'async_trait>( &'life0 self, object_seq: u64, content: Bytes, ) -> Pin<Box<dyn Future<Output = Result<PutResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get<'life0, 'async_trait>( &'life0 self, object_seq: u64, ) -> Pin<Box<dyn Future<Output = Result<Bytes>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_range<'life0, 'async_trait>( &'life0 self, object_seq: u64, offset: u64, len: u64, ) -> Pin<Box<dyn Future<Output = Result<Bytes>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ListedObject>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn object_path(&self, object_seq: u64) -> String