Skip to main content
Defined in: scheduler/ScheduleStore.ts:77 Storage for durable scheduled tasks (BotConfig.scheduler.store). In memory by default; SQLiteStore and RedisStore (among others) provide one through store.schedules().

Methods

start()?

Defined in: scheduler/ScheduleStore.ts:79 Optional setup (schema, connection) — called by the scheduler before first use. Must be idempotent.

Returns

Promise<void>

get()

Defined in: scheduler/ScheduleStore.ts:80

Parameters

Returns

Promise<ScheduleRecord | null>

register()

Defined in: scheduler/ScheduleStore.ts:87 Insert the task if absent. If it exists with the same kind and spec, keep it untouched (that is how a restart keeps its nextRunAt); if either differs, overwrite kind, spec and nextRunAt with the given ones (the fencing token is kept). Returns the stored record.

Parameters

Returns

Promise<ScheduleRecord>

claimDue()

Defined in: scheduler/ScheduleStore.ts:94 Atomic claim: succeeds only when nextRunAt !== null && nextRunAt <= now and the record has no live lease (leaseUntil absent or <= now). Then it sets leaseOwner = owner, leaseUntil = now + leaseMs and increments fencingToken. Returns null otherwise (not due, leased elsewhere, or unknown id).

Parameters

Returns

Promise<ClaimResult | null>

renew()

Defined in: scheduler/ScheduleStore.ts:96 Set leaseUntil only if fencingToken still matches; false means the lease was lost.

Parameters

Returns

Promise<boolean>

complete()

Defined in: scheduler/ScheduleStore.ts:101 Commit an occurrence only if fencingToken still matches: write the patch, clear the lease and set updatedAt = now. false when stale (claimed again since) or deleted.

Parameters

Returns

Promise<boolean>

delete()

Defined in: scheduler/ScheduleStore.ts:106 Remove the record. The id’s fencing token is kept as a high-water mark: a later register() of the same id starts from it, so tokens never go backwards per id.

Parameters

Returns

Promise<void>

list()

Defined in: scheduler/ScheduleStore.ts:108 Every stored record (orphans included), in no particular order.

Returns

Promise<ScheduleRecord[]>