Class: InMemoryJobStore
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:123
Dispatch jobs in memory, for tests and single-process hosts: its leases hold within one process.
Implements
Constructors
Constructor
new InMemoryJobStore():
InMemoryJobStore
Returns
InMemoryJobStore
Methods
cancel()
cancel(
runId):Promise<"cancelled"|"already_dispatched"|"missing">
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:168
Marks the job cancelled. already_dispatched when the bot is out: the caller tells it to leave instead. A job under a live lease is cancelled too, and its dispatcher learns it from markDispatched.
Parameters
runId
string
Returns
Promise<"cancelled" | "already_dispatched" | "missing">
Implementation of
forget()
forget(
runId):Promise<void>
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:124
Optional whole-run eviction for in-memory hosts after terminal cleanup and the retention grace. Durable stores omit it to retain their records. Call only after producers have stopped; forgetting removes fences too.
Parameters
runId
string
Returns
Promise<void>
Implementation of
get()
get(
runId):Promise<MeetingJob|undefined>
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:175
The run's job, or undefined when there is none.
Parameters
runId
string
Returns
Promise<MeetingJob | undefined>
Implementation of
lease()
lease(
holder,now,ttlMs):Promise<MeetingJob|undefined>
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:134
The next due, uncancelled, undispatched job whose lease is absent or expired, leased to holder until now + ttlMs.
Parameters
holder
string
now
number
ttlMs
number
Returns
Promise<MeetingJob | undefined>
Implementation of
listDispatched()
listDispatched():
Promise<MeetingJob[]>
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:179
Every dispatched job: what reconciliation compares with the providers' usage.
Returns
Promise<MeetingJob[]>
Implementation of
markDispatched()
markDispatched(
runId,holder,workerId):Promise<{cancelled:boolean;recorded:boolean; }>
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:151
Records the dispatch for the lease's holder and answers whether a cancel arrived meanwhile (then the dispatcher tells
the bot to leave at once). A dispatch can outlive its lease and another holder can take the job: when holder no
longer holds the lease, or the job is gone, nothing is recorded and recorded is false.
Parameters
runId
string
holder
string
workerId
string | undefined
Returns
Promise<{ cancelled: boolean; recorded: boolean; }>
Implementation of
release()
release(
runId,holder,retryAt):Promise<boolean>
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:160
Releases the holder's lease without dispatching (the dispatch failed and will be retried), moving the job's due time
to retryAt. False, and nothing changes, when holder no longer holds the lease or the job is gone.
Parameters
runId
string
holder
string
retryAt
number
Returns
Promise<boolean>
Implementation of
remove()
remove(
runId):Promise<void>
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:182
Deletes the run's job.
Parameters
runId
string
Returns
Promise<void>
Implementation of
renew()
renew(
runId,holder,now,ttlMs):Promise<boolean>
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:145
Extends a lease the holder still holds; false when it expired or another holder took it, and then the holder must stop.
Parameters
runId
string
holder
string
now
number
ttlMs
number
Returns
Promise<boolean>
Implementation of
schedule()
schedule(
job):Promise<void>
Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:129
Adds the run's job, due at dispatchAt; for an existing job moves only dispatchAt, preserving the lease, worker, dispatched and cancelled fields.
Parameters
job
dispatchAt
number
runId
string
Returns
Promise<void>