Struct SqliteEnvelopeStore

pub struct SqliteEnvelopeStore { /* private fields */ }

Struct that offers access to a SQLite-based store of [Envelope]s.

The goal of this struct is to hide away all the complexity of dealing with the database for reading and writing envelopes.

Implementations

impl SqliteEnvelopeStore

pub fn new( partition_id: u8, db: Pool<Sqlite>, refresh_frequency: Duration, ) -> Self

Initializes the SqliteEnvelopeStore with a supplied [Pool].

pub async fn prepare( partition_id: u8, config: &Config, ) -> Result<SqliteEnvelopeStore, SqliteEnvelopeStoreError>

Prepares the SqliteEnvelopeStore by running all the necessary migrations and preparing the folders where data will be stored.

pub async fn insert_batch( &mut self, envelopes: DatabaseBatch, ) -> Result<(), SqliteEnvelopeStoreError>

Inserts one or more envelopes into the database.

pub async fn delete_batch( &mut self, own_key: ProjectKey, sampling_key: ProjectKey, ) -> Result<Option<DatabaseBatch>, SqliteEnvelopeStoreError>

Deletes and returns at most limit [Envelope]s from the database.

pub async fn project_key_pairs( &self, ) -> Result<HashSet<ProjectKeyPair>, SqliteEnvelopeStoreError>

Returns a set of project key pairs, representing all the unique combinations of own_key and project_key that are found in the database.

pub fn usage(&self) -> u64

Returns an approximate measure of the used size of the database.

pub async fn total_count(&self) -> Result<u64, SqliteEnvelopeStoreError>

Returns the total count of envelopes stored in the database.

Trait Implementations

impl Clone for SqliteEnvelopeStore

fn clone(&self) -> SqliteEnvelopeStore

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqliteEnvelopeStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.