Struct TenantDovecote 

pub struct TenantDovecote { /* private fields */ }

Ordinary SQLite operations restricted to one validated tenant.

Implementations

impl TenantDovecote

pub const fn tenant_id(&self) -> &TenantId

Returns this handle’s tenant identifier.

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

Borrows the underlying pool.

pub const fn busy_config(&self) -> BusyConfig

Returns this handle’s busy policy.

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

Verifies the installed schema.

Errors

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

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

Begins a caller-owned writer transaction.

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 for Self::begin_write.

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 enqueue<'c>( &self, tx: &mut Transaction<'c, Sqlite>, event: NewEvent, ) -> Result<EnqueueOutcome, EnqueueError>

Enqueues in a caller-owned transaction.

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>, event: NewEvent, state: ImportedDeliveryState, ) -> Result<ImportOutcome, ImportError>

Imports one event and delivery state in a caller-owned transaction.

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>, row_id: RowId, delivered_at: OffsetDateTime, ) -> Result<FinalizeOutcome, FinalizeError>

Finalizes one migration delivery in a caller-owned transaction.

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 page( &self, after: Option<RowId>, limit: Limit, ) -> Result<Vec<PagedEvent>, PageError>

Reads one tenant page.

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 one 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 one tenant’s pending deliveries.

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 renew( &self, row_id: RowId, token: &ClaimToken, lease: Lease, ) -> Result<(), MutationError>

Renews one tenant claim.

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, row_id: RowId, token: &ClaimToken, ) -> Result<(), MutationError>

Acknowledges one tenant claim.

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, row_id: RowId, token: &ClaimToken, failure: &Failure, delay: Delay, ) -> Result<(), MutationError>

Retries one tenant claim.

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, row_id: RowId, token: &ClaimToken, delay: Delay, ) -> Result<(), MutationError>

Releases one tenant claim.

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, row_id: RowId, token: &ClaimToken, reason: &QuarantineReason, ) -> Result<(), MutationError>

Quarantines one tenant claim.

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 TenantDovecote

fn clone(&self) -> TenantDovecote

Returns a duplicate of the value.

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

Performs copy-assignment from source.