Struct AdminDovecote 

pub struct AdminDovecote { /* private fields */ }

Explicit administrative SQLite handle.

Implementations

impl AdminDovecote

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

Borrows the underlying pool.

pub async fn page( &self, after: Option<RowId>, limit: Limit, ) -> Result<Vec<PagedEvent>, PageError>

Reads all tenants and returns tenant metadata on each row.

Errors

Returns an error for incompatible schema, invalid stored event or delivery state, or a database failure. No delivery state is changed.

pub async fn begin_snapshot(&self) -> Result<SnapshotPager, PageError>

Begins an all-tenant snapshot.

Errors

Returns an error if the backend cannot establish the required snapshot, the schema is incompatible, or a database operation fails.

pub async fn claim( &self, worker: WorkerId, lease: Lease, limit: Limit, ) -> Result<Vec<ClaimedEvent>, ClaimError>

Claims across tenants.

Errors

Returns an error for incompatible backend or schema, invalid stored state, attempt-counter overflow, unavailable entropy, or database failure. The owned transaction is rolled back on pre-commit failure; an unknown commit requires recovery from durable state rather than assuming no claim occurred.

pub async fn enqueue<'c>( &self, tx: &mut Transaction<'c, Sqlite>, tenant: TenantId, event: NewEvent, ) -> Result<EnqueueOutcome, EnqueueError>

Enqueues for an explicitly named tenant.

Errors

Returns an identity conflict for different immutable content, a schema or backend incompatibility, invalid stored data, or a database error. The caller must roll back its transaction on failure; this method never commits it.

pub async fn import_for_migration<'c>( &self, tx: &mut Transaction<'c, Sqlite>, tenant: TenantId, event: NewEvent, state: ImportedDeliveryState, ) -> Result<ImportOutcome, ImportError>

Imports for an explicitly named tenant.

Errors

Returns a conflict if existing immutable content or delivery history differs, or an error for unsupported history, incompatible schema, invalid stored data, or database failure. Roll back the caller-owned transaction on failure.

pub async fn finalize_pending_delivery_for_migration<'c>( &self, tx: &mut Transaction<'c, Sqlite>, tenant: TenantId, row_id: RowId, delivered_at: OffsetDateTime, ) -> Result<FinalizeOutcome, FinalizeError>

Finalizes for an explicitly named tenant.

Errors

Returns an error for invalid occurrence time, conflicting or non-pending delivery history, incompatible schema, or database failure. The caller owns rollback and commit; a failed operation must not be committed.

pub async fn renew( &self, tenant: TenantId, row_id: RowId, token: &ClaimToken, lease: Lease, ) -> Result<(), MutationError>

Renews a claim for an explicitly named tenant.

Errors

Returns LostClaim if the token no longer owns an unexpired claim, or an error for invalid stored state, duration overflow, or database failure.

pub async fn ack( &self, tenant: TenantId, row_id: RowId, token: &ClaimToken, ) -> Result<(), MutationError>

Acknowledges a claim for an explicitly named tenant.

Errors

Returns LostClaim if the token no longer owns an unexpired claim, or an error for invalid stored state or database failure. A lost commit response requires durable-state recovery; delivery remains at least once.

pub async fn retry( &self, tenant: TenantId, row_id: RowId, token: &ClaimToken, failure: &Failure, delay: Delay, ) -> Result<(), MutationError>

Retries a claim for an explicitly named tenant.

Errors

Returns LostClaim if the token no longer owns an unexpired claim, or an error for invalid stored state, delay overflow, or database failure.

pub async fn release( &self, tenant: TenantId, row_id: RowId, token: &ClaimToken, delay: Delay, ) -> Result<(), MutationError>

Releases a claim for an explicitly named tenant.

Errors

Returns LostClaim if the token no longer owns an unexpired claim, or an error for invalid stored state, delay overflow, or database failure.

pub async fn quarantine( &self, tenant: TenantId, row_id: RowId, token: &ClaimToken, reason: &QuarantineReason, ) -> Result<(), MutationError>

Quarantines a claim for an explicitly named tenant.

Errors

Returns LostClaim if the token no longer owns an unexpired claim, or an error for invalid stored state or database failure.

Trait Implementations

impl Clone for AdminDovecote

fn clone(&self) -> AdminDovecote

Returns a duplicate of the value.

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

Performs copy-assignment from source.