Class D1IdempotencyStore

constructor

• new D1IdempotencyStore(
      db: IdempotencyDatabase,
      options?: D1IdempotencyStoreOptions,
  ): D1IdempotencyStore

  Parameters

  • db: IdempotencyDatabase
  • options: D1IdempotencyStoreOptions = {}

  Returns D1IdempotencyStore

ReadonlypendingTtlMs

get

• get(key: string): Promise<IdempotencyRecord | undefined>

  Return a completed record for key, or undefined while absent or pending.

  Parameters

  • key: string

  Returns Promise<IdempotencyRecord | undefined>

put

• put(key: string, record: IdempotencyRecord, token?: string): Promise<void>

  Finalize a key's record. token is the lease returned by an atomic reserve(): when supplied, the store finalizes ONLY if the key still belongs to that lease. A stale holder whose lease was taken over cannot overwrite the new result. Omit the token on the legacy get/put path, which upserts unconditionally (same-isolate protection only).

  Parameters

  • key: string
  • record: IdempotencyRecord
  • Optionaltoken: string

  Returns Promise<void>

release

• release(key: string, token?: string): Promise<void>

  Drop a pending reservation after a failed execute — failures stay retryable. token is the lease from reserve(): when supplied, only the matching lease's pending row is dropped, so a stale holder cannot delete a newer claim.

  Parameters

  • key: string
  • Optionaltoken: string

  Returns Promise<void>

reserve

• reserve(key: string): Promise<IdempotencyReservation>

  Atomically reserve a key, replay a completed result, or report contention.

  Parameters

  • key: string

  Returns Promise<IdempotencyReservation>