Struct Freezer 

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

Implementation of Freezer.

Implementations

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

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

Initialize a new Freezer instance.

pub async fn init_with_checkpoint( context: E, config: Config<V::Cfg>, checkpoint: Option<Checkpoint>, ) -> Result<Self, Error>

Initialize a new Freezer instance with a Checkpoint.

pub async fn put(&mut self, key: K, value: V) -> Result<Cursor, Error>

Put a key-value pair into the Freezer.

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

Get the value for a given Identifier.

If a Cursor is known for the required key, it is much faster to use it than searching for a key.

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

Sync all pending data in Freezer.

If the table needs to be resized, the resize will begin during this sync. The resize operation is performed incrementally across multiple sync calls to avoid a large latency spike (or unexpected long latency for Freezer::put). Each sync will process up to table_resize_chunk_size entries until the resize is complete.

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

Close the Freezer and return a Checkpoint for recovery.

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

Close and remove any underlying blobs created by the Freezer.