Struct SqliteDovecote 

pub struct SqliteDovecote { /* private fields */ }

SQLite adapter for Dovecote’s durable event and delivery schema.

Implementations

impl SqliteDovecote

pub fn new(pool: SqlitePool) -> Self

Creates an adapter with the documented bounded busy policy.

pub const fn with_busy_config(pool: SqlitePool, busy: BusyConfig) -> Self

Creates an adapter with an explicit busy retry policy.

pub const fn pool(&self) -> &SqlitePool

Borrows the pool used by this adapter.

pub const fn busy_config(&self) -> BusyConfig

Returns the bounded busy policy used by adapter operations.

pub async fn begin_write( &self, ) -> Result<Transaction<'static, Sqlite>, EnqueueError>

Begins the caller transaction used for enqueue and application state. It acquires SQLite’s single writer slot before any adapter reads.

Errors

Returns an error for invalid busy configuration or if the SQLite writer reservation cannot be acquired within the configured busy budget.

pub async fn begin_enqueue( &self, ) -> Result<Transaction<'static, Sqlite>, EnqueueError>

Alias emphasizing that the returned transaction is suitable for TenantDovecote::enqueue.

Errors

Returns an error for invalid busy configuration or if the SQLite writer reservation cannot be acquired within the configured busy budget.

pub fn for_tenant(&self, tenant_id: TenantId) -> TenantDovecote

Creates an ordinary handle restricted to one validated tenant.

pub fn admin(&self) -> AdminDovecote

Creates the explicit administrative handle for all-tenant reads and named writes.

pub async fn check_schema(&self) -> Result<(), SchemaError>

Verifies that the pool’s current SQLite schema satisfies Dovecote.

Errors

Returns an error for an unsupported backend, missing or incompatible migration markers, tables, constraints or indexes, or failed catalog reads.

Trait Implementations

impl Clone for SqliteDovecote

fn clone(&self) -> SqliteDovecote

Returns a duplicate of the value.

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

Performs copy-assignment from source.