Struct Archive 

pub struct Archive<E: Storage + Metrics + Clock, K: Array, V: Codec> { /* private fields */ }

An immutable key-value store for ordered data with a minimal memory footprint.

Implementations

impl<E: Storage + Metrics + Clock, K: Array, V: Codec> Archive<E, K, V>

pub async fn init(context: E, cfg: Config<V::Cfg>) -> Result<Self, Error>

Initialize a new Archive with the given Config.

Trait Implementations

impl<E: Storage + Metrics + Clock, K: Array, V: Codec> Archive for Archive<E, K, V>

type Key = K

The type of the key.

type Value = V

The type of the value.

async fn put(&mut self, index: u64, key: K, data: V) -> Result<(), Error>

Store an item in Archive. Both indices and keys are assumed to both be globally unique.

async fn get(&self, identifier: Identifier<'_, K>) -> Result<Option<V>, Error>

Retrieve an item from Archive.

async fn has(&self, identifier: Identifier<'_, K>) -> Result<bool, Error>

Check if an item exists in Archive.

async fn sync(&mut self) -> Result<(), Error>

Sync all pending writes.

fn next_gap(&self, index: u64) -> (Option<u64>, Option<u64>)

Retrieve the end of the current range including index (inclusive) and the start of the next range after index (if it exists).

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

Close Archive (and underlying storage).

async fn destroy(self) -> Result<(), Error>

Remove all persistent data created by this Archive.

fn put_sync( &mut self, index: u64, key: Self::Key, value: Self::Value, ) -> impl Future<Output = Result<(), Error>>

Perform a Archive::put and Archive::sync in a single operation.