Class PostgresJobRepository

Readonlystorage

attempts

• attempts(namespace: string, id: string): Promise<JobAttempt[]>

  Read attempt audit history, scoped through the owning run.

  Parameters

  • namespace: string
  • id: string

  Returns Promise<JobAttempt[]>

cancel

• cancel(namespace: string, id: string): Promise<boolean>

  Fence a running owner immediately; physical cancellation is cooperative.

  Parameters

  • namespace: string
  • id: string

  Returns Promise<boolean>

claim

• claim(
      namespace: string,
      supported: readonly SupportedJob[],
      leaseMs: number,
  ): Promise<RunRecord | undefined>

  Atomically acquire one run. Expired attempts are recorded before any retry.

  Parameters

  • namespace: string
  • supported: readonly SupportedJob[]
  • leaseMs: number

  Returns Promise<RunRecord | undefined>

cleanup

• cleanup(namespace: string, limit?: number): Promise<number>

  Purge terminal data only; deduplication ends when the retained run is removed.

  Parameters

  • namespace: string
  • Optionallimit: number

  Returns Promise<number>

complete

• complete(
      namespace: string,
      id: string,
      token: string,
      output: JsonValue,
  ): Promise<void>

  Publish output and terminal event atomically, rejecting stale owners.

  Parameters

  • namespace: string
  • id: string
  • token: string
  • output: JsonValue

  Returns Promise<void>

dispatch

• dispatch(
      namespace: string,
      scheduleLimit?: number,
      replayLimit?: number,
  ): Promise<number>

  Atomically materialize due occurrences and advance locked schedule cursors.

  Parameters

  • namespace: string
  • OptionalscheduleLimit: number
  • OptionalreplayLimit: number

  Returns Promise<number>

enqueue

• enqueue(submission: JobSubmission): Promise<RunRecord>

  Resolve only after persisted acceptance (or the enclosing transaction commit).

  Parameters

  • submission: JobSubmission

  Returns Promise<RunRecord>

events

• events(
      namespace: string,
      id: string,
      after: number,
      limit?: number,
  ): Promise<JobEvent[]>

  Read a bounded page of committed events, scoped through the owning run.

  Parameters

  • namespace: string
  • id: string
  • after: number
  • Optionallimit: number

  Returns Promise<JobEvent[]>

fail

• fail(
      namespace: string,
      id: string,
      token: string,
      error: JobError,
      retryable?: boolean,
      interrupted?: boolean,
  ): Promise<void>

  Persist a failure or shutdown interruption and its retry decision.

  Parameters

  • namespace: string
  • id: string
  • token: string
  • error: JobError
  • Optionalretryable: boolean
  • Optionalinterrupted: boolean

  Returns Promise<void>

get

• get(namespace: string, id: string): Promise<RunRecord | undefined>

  Read a detached internal record. Applications should use JobScheduler.getRun.

  Parameters

  • namespace: string
  • id: string

  Returns Promise<RunRecord | undefined>

health

• health(namespace: string): Promise<JobRepositoryHealth>

  Inspect aggregate queue health without reading payloads.

  Parameters

  • namespace: string

  Returns Promise<JobRepositoryHealth>

heartbeat

• heartbeat(
      namespace: string,
      id: string,
      token: string,
      leaseMs: number,
  ): Promise<void>

  Renew an unexpired lease; a late heartbeat cannot resurrect ownership.

  Parameters

  • namespace: string
  • id: string
  • token: string
  • leaseMs: number

  Returns Promise<void>

pauseSchedule

• pauseSchedule(namespace: string, id: string, paused?: boolean): Promise<boolean>

  Pausing stops new occurrences, not already accepted runs.

  Parameters

  • namespace: string
  • id: string
  • Optionalpaused: boolean

  Returns Promise<boolean>

removeSchedule

• removeSchedule(namespace: string, id: string): Promise<boolean>

  Tombstone a trigger while preserving identity/revision history.

  Parameters

  • namespace: string
  • id: string

  Returns Promise<boolean>

report

• report(
      namespace: string,
      id: string,
      token: string,
      progress: JsonValue,
  ): Promise<void>

  Commit ordered progress within the ownership transaction.

  Parameters

  • namespace: string
  • id: string
  • token: string
  • progress: JsonValue

  Returns Promise<void>

upsertSchedule

• upsertSchedule(submission: ScheduleSubmission): Promise<ScheduleRecord>

  Idempotent identical registration; changed specs create future-only revisions.

  Parameters

  • submission: ScheduleSubmission

  Returns Promise<ScheduleRecord>