Class SqlJobStore

Postgres dispatch jobs with atomic leases and holder-checked writes.

Implements

IJobStore

Index

Constructors

Methods

schedule lease renew markDispatched release cancel get listDispatched remove

Constructors

constructor

new SqlJobStore(opts): SqlJobStore
Checks the adapter capabilities and prefix without creating tables.
Parameters
- opts: SqlStoreOptions
Returns SqlJobStore
- Defined in src/io/channels/meetings/stores/sql.ts:408

Methods

schedule

schedule(job): Promise<void>
Schedules a job; an existing job keeps its lease, dispatch and cancellation fields.
Parameters
- job: {
  runId: string;
  dispatchAt: number;
  }
  - runId: string
  - dispatchAt: number
Returns Promise<void>
Implementation of IJobStore.schedule
- Defined in src/io/channels/meetings/stores/sql.ts:416

lease

lease(holder, now, ttlMs): Promise<undefined | MeetingJob>
One statement: the row is locked, skipped by any other taker, and leased in the same UPDATE.
Parameters
- holder: string
- now: number
- ttlMs: number
Returns Promise<undefined | MeetingJob>
Implementation of IJobStore.lease
- Defined in src/io/channels/meetings/stores/sql.ts:420

renew

renew(runId, holder, now, ttlMs): Promise<boolean>
Extends an unexpired lease only for its current holder.
Parameters
- runId: string
- holder: string
- now: number
- ttlMs: number
Returns Promise<boolean>
Implementation of IJobStore.renew
- Defined in src/io/channels/meetings/stores/sql.ts:433

markDispatched

markDispatched(runId, holder, workerId): Promise<{
recorded: boolean;
cancelled: boolean;
}>
Records the holder's dispatch and reports a cancellation that arrived during it.
Parameters
- runId: string
- holder: string
- workerId: undefined | string
Returns Promise<{
recorded: boolean;
cancelled: boolean;
}>
Implementation of IJobStore.markDispatched
- Defined in src/io/channels/meetings/stores/sql.ts:438

release

release(runId, holder, retryAt): Promise<boolean>
Releases the holder's lease and moves the job's due time to its retry.
Parameters
- runId: string
- holder: string
- retryAt: number
Returns Promise<boolean>
Implementation of IJobStore.release
- Defined in src/io/channels/meetings/stores/sql.ts:448

cancel

cancel(runId): Promise<"cancelled" | "already_dispatched" | "missing">
Cancels a pending job or reports that the caller must leave an already dispatched bot.
Parameters
- runId: string
Returns Promise<"cancelled" | "already_dispatched" | "missing">
Implementation of IJobStore.cancel
- Defined in src/io/channels/meetings/stores/sql.ts:453

get

get(runId): Promise<undefined | MeetingJob>
Reads one dispatch job.
Parameters
- runId: string
Returns Promise<undefined | MeetingJob>
Implementation of IJobStore.get
- Defined in src/io/channels/meetings/stores/sql.ts:463

listDispatched

listDispatched(): Promise<MeetingJob[]>
Lists the dispatched jobs reconciliation compares with provider usage.

Returns Promise<MeetingJob[]>
Implementation of IJobStore.listDispatched
- Defined in src/io/channels/meetings/stores/sql.ts:468

remove

remove(runId): Promise<void>
Removes a run's job.
Parameters
- runId: string
Returns Promise<void>
Implementation of IJobStore.remove
- Defined in src/io/channels/meetings/stores/sql.ts:472