AxEventStore

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

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

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<
  | Readonly<AxEventContinuation>
| undefined>;

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

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

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

isIdle(): Promise<boolean>;

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

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

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>;