Struct relay_server::SqliteEnvelopeStack

pub struct SqliteEnvelopeStack { /* private fields */ }

An EnvelopeStack that is implemented on an SQLite database.

For efficiency reasons, the implementation has an in-memory buffer that is periodically spooled to disk in a batched way.

Implementations

impl SqliteEnvelopeStack

pub fn new( envelope_store: SqliteEnvelopeStore, disk_batch_size: usize, max_batches: usize, own_key: ProjectKey, sampling_key: ProjectKey, check_disk: bool, ) -> Self

Creates a new empty SqliteEnvelopeStack.

Trait Implementations

impl Debug for SqliteEnvelopeStack

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

Formats the value using the given formatter.

impl EnvelopeStack for SqliteEnvelopeStack

type Error = SqliteEnvelopeStackError

The error type that is returned when an error is encountered during reading or writing the EnvelopeStack.

async fn push(&mut self, envelope: Box<Envelope>) -> Result<(), Self::Error>

Pushes an [Envelope] on top of the stack.

async fn peek(&mut self) -> Result<Option<&Envelope>, Self::Error>

Peeks the [Envelope] on top of the stack.

async fn pop(&mut self) -> Result<Option<Box<Envelope>>, Self::Error>

Pops the [Envelope] on top of the stack.

fn flush(self) -> Vec<Box<Envelope>>

Persists all envelopes in the EnvelopeStacks to external storage, if possible, and consumes the stack provider.