Struct AdminDovecote 

pub struct AdminDovecote { /* private fields */ }

Explicit all-tenant PostgreSQL Dovecote operations.

Implementations

impl AdminDovecote

pub fn pool(&self) -> &PgPool

Borrows the pool used by this handle.

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

Enqueues an event for an explicitly named tenant.

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

Imports one event and legacy state for an explicitly named tenant.

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

Finalizes one migration row for an explicitly named tenant.

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

Reads a live page across all tenants.

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

Begins a finite snapshot pager across all tenants.

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

Claims pending and expired deliveries across all tenants.

pub async fn renew( &self, tenant_id: TenantId, row_id: RowId, claim_token: &ClaimToken, lease_for: Lease, ) -> Result<(), MutationError>

Renews one claim for an explicitly named tenant.

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

Acknowledges one claim for an explicitly named tenant.

pub async fn retry( &self, tenant_id: TenantId, row_id: RowId, claim_token: &ClaimToken, failure: &Failure, backoff: Delay, ) -> Result<(), MutationError>

Retries one claim for an explicitly named tenant.

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

Releases one claim for an explicitly named tenant.

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

Quarantines one claim for an explicitly named tenant.

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.