Struct nimbus::stateful::persistence::SingleStore

pub struct SingleStore { /* private fields */ }

A wrapper for an Rkv store. Implemented to allow any value which supports serde to be used.

Implementations

impl SingleStore

pub fn new(store: SingleStore<SafeModeDatabase>) -> Self

pub fn put<T: Serialize + for<'de> Deserialize<'de>>( &self, writer: &mut Writer<'_>, key: &str, persisted_data: &T ) -> Result<()>

pub fn delete(&self, writer: &mut Writer<'_>, key: &str) -> Result<()>

pub fn clear(&self, writer: &mut Writer<'_>) -> Result<()>

pub fn get<'r, T, R>(&self, reader: &'r R, key: &str) -> Result<Option<T>>

where R: Readable<'r>, T: Serialize + for<'de> Deserialize<'de>,

pub fn try_collect_all<'r, T, R>(&self, reader: &'r R) -> Result<Vec<T>>

where R: Readable<'r>, T: Serialize + for<'de> Deserialize<'de>,

Fork of collect_all that simply drops records that fail to read rather than simply returning an error up the stack. This likely wants to be just a parameter to collect_all, but for now….

pub fn collect_all<'r, T, R>(&self, reader: &'r R) -> Result<Vec<T>>

where R: Readable<'r>, T: Serialize + for<'de> Deserialize<'de>,