AxEventStore

addDeadLetter(deadLetter: Readonly<AxEventDeadLetter>): Promise<void>;

claim(
   workerId: string, 
   now: number, 
leaseMs?: number): Promise<undefined | AxEventDelivery>;

optional close(): void | Promise<void>;

completeContinuation(id: string): Promise<void>;

enqueue(request: Readonly<AxEventEnqueueRequest>, signal?: AbortSignal): Promise<AxEventPublishReceipt>;

findContinuation(
   identityScope: string, 
   correlation: Readonly<AxEventCorrelationKey>, 
   now: number): Promise<
  | undefined
| Readonly<AxEventContinuation>>;

getDeadLetter(id: string): Promise<
  | undefined
| Readonly<AxEventDeadLetter>>;

getDelivery(deliveryId: string): Promise<
  | undefined
| Readonly<AxEventDelivery>>;

getRun(runId: string): Promise<
  | undefined
| Readonly<AxEventRun<unknown>>>;

isIdle(): Promise<boolean>;

listDeadLetters(): Promise<readonly Readonly<AxEventDeadLetter>[]>;

nextAvailableAt(now: number): Promise<undefined | number>;

redriveDelivery(deliveryId: string, now: number): Promise<void>;

registerContinuation(continuation: Readonly<AxEventContinuation>): Promise<void>;

removeDeadLetter(id: string): Promise<void>;

renewClaim(
   deliveryId: string, 
   workerId: string, 
   fencingToken: number, 
leaseExpiresAt: number): Promise<void>;

saveDelivery(delivery: Readonly<AxEventDelivery>): Promise<void>;

saveRun(run: Readonly<AxEventRun>): Promise<void>;

waitForWork(signal?: AbortSignal): Promise<void>;