MemoryScheduleStore

Class exported by @botmesh/core/spi.

Defined in: scheduler/ScheduleStore.ts:172

Reference, in-process ScheduleStore. Nothing survives the process.

Implements

• ScheduleStore

Constructors

Constructor

new MemoryScheduleStore(): MemoryScheduleStore;

Returns

MemoryScheduleStore

Methods

get()

get(id): Promise<ScheduleRecord | null>;

Defined in: scheduler/ScheduleStore.ts:177

Parameters

Parameter	Type
id	string

Returns

Promise<ScheduleRecord | null>

Implementation of

ScheduleStore.get

---

register()

register(rec, now): Promise<ScheduleRecord>;

Defined in: scheduler/ScheduleStore.ts:182

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

Parameter	Type
rec	Pick<ScheduleRecord, "id" | "kind" | "spec" | "nextRunAt">
now	number

Returns

Promise<ScheduleRecord>

Implementation of

ScheduleStore.register

---

claimDue()

claimDue(
   id, 
   owner, 
   now, 
   leaseMs
): Promise<ClaimResult | null>;

Defined in: scheduler/ScheduleStore.ts:199

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

Parameter	Type
id	string
owner	string
now	number
leaseMs	number

Returns

Promise<ClaimResult | null>

Implementation of

ScheduleStore.claimDue

---

renew()

renew(
   id, 
   fencingToken, 
   leaseUntil
): Promise<boolean>;

Defined in: scheduler/ScheduleStore.ts:209

Set leaseUntil only if fencingToken still matches; false means the lease was lost.

Parameters

Parameter	Type
id	string
fencingToken	number
leaseUntil	number

Returns

Promise<boolean>

Implementation of

ScheduleStore.renew

---

complete()

complete(
   id, 
   fencingToken, 
   patch, 
   now
): Promise<boolean>;

Defined in: scheduler/ScheduleStore.ts:216

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

Parameter	Type
id	string
fencingToken	number
patch	CompletePatch
now	number

Returns

Promise<boolean>

Implementation of

ScheduleStore.complete

---

delete()

delete(id): Promise<void>;

Defined in: scheduler/ScheduleStore.ts:225

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

Parameter	Type
id	string

Returns

Promise<void>

Implementation of

ScheduleStore.delete

---

list()

list(): Promise<ScheduleRecord[]>;

Defined in: scheduler/ScheduleStore.ts:232

Every stored record (orphans included), in no particular order.

Returns

Promise<ScheduleRecord[]>

Implementation of

ScheduleStore.list