Struct TenantDovecote 

pub struct TenantDovecote { /* private fields */ }

PostgreSQL Dovecote operations restricted to one validated tenant.

Implementations

impl TenantDovecote

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

Returns this handle’s validated tenant identifier.

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

Borrows the pool used by this handle.

pub async fn bind_tenant<'c>( &self, transaction: &mut Transaction<'c, Postgres>, ) -> Result<(), Error>

Binds this tenant to a transaction for the optional PostgreSQL RLS profile. Adapter predicates remain active even without RLS.

Errors

Returns the database error if binding transaction-local tenant context fails. The caller must roll back the transaction before retrying.

pub async fn enqueue<'c>( &self, transaction: &mut Transaction<'c, Postgres>, event: NewEvent, ) -> Result<EnqueueOutcome, EnqueueError>

Enqueues an event for this tenant in the 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, transaction: &mut Transaction<'c, Postgres>, event: NewEvent, state: ImportedDeliveryState, ) -> Result<ImportOutcome, ImportError>

Imports one event and legacy state for this 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, transaction: &mut Transaction<'c, Postgres>, row_id: RowId, delivered_at: OffsetDateTime, ) -> Result<FinalizeOutcome, FinalizeError>

Finalizes one canonical pending migration row for this 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 page( &self, after_row_id: Option<RowId>, limit: Limit, ) -> Result<Vec<PagedEvent>, PageError>

Reads a live page restricted to this tenant.

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 a finite snapshot pager restricted to this tenant.

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_for: Lease, limit: Limit, ) -> Result<Vec<ClaimedEvent>, ClaimError>

Claims pending and expired deliveries for this tenant.

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, claim_token: &ClaimToken, lease_for: Lease, ) -> Result<(), MutationError>

Renews one current claim for this 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, row_id: RowId, claim_token: &ClaimToken, ) -> Result<(), MutationError>

Acknowledges one current claim for this 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, row_id: RowId, claim_token: &ClaimToken, failure: &Failure, backoff: Delay, ) -> Result<(), MutationError>

Returns one current claim to pending for this 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, row_id: RowId, claim_token: &ClaimToken, delay: Delay, ) -> Result<(), MutationError>

Releases one current claim for this 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, row_id: RowId, claim_token: &ClaimToken, reason: &QuarantineReason, ) -> Result<(), MutationError>

Quarantines one current claim for this 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 TenantDovecote

fn clone(&self) -> TenantDovecote

Returns a duplicate of the value.

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

Performs copy-assignment from source.