Interface WorkQueueSweeperOptions

interface WorkQueueSweeperOptions {
    AcquireLock?: (
        source: WorkQueueExecutorSource,
        contextUser: UserInfo,
    ) => Promise<SweepLock>;
    CreateLedger?: (
        executor: WorkQueueSqlExecutor,
        contextUser: UserInfo,
    ) => Pick<DeduplicationLedger, "PurgeExpired">;
    MaxPurgeBatchesPerRun: number;
    PurgeBatchSize: number;
}

Index

Properties

AcquireLock? CreateLedger? MaxPurgeBatchesPerRun PurgeBatchSize

Properties

`Optional`AcquireLock

AcquireLock?: (
source: WorkQueueExecutorSource,
contextUser: UserInfo,
) => Promise<SweepLock>

Test seam. Default: plan 05's TryAcquireSweepLock — an independent executor guarded by the transaction-owned sweep lock.

`Optional`CreateLedger

CreateLedger?: (
executor: WorkQueueSqlExecutor,
contextUser: UserInfo,
) => Pick<DeduplicationLedger, "PurgeExpired">

Test seam. Default: a DeduplicationLedger over the lock's executor.

MaxPurgeBatchesPerRun

MaxPurgeBatchesPerRun: number

PurgeBatchSize

PurgeBatchSize: number