Interface: IEventStore
Defined in: packages/agentos/src/io/channels/meetings/stores/types.ts:143
A run's events: stable ids, a sequence number per run, and payloads a purge removes.
Methods
append()
append(
event):Promise<{inserted:boolean;seq:number; }>
Defined in: packages/agentos/src/io/channels/meetings/stores/types.ts:147
Inserts with the next sequence number of the run; a repeated eventId is not inserted and answers the existing sequence. Behind the fence a content event is stored without its payload, marked purged.
Parameters
event
Omit<MeetingEvent, "seq">
Returns
Promise<{ inserted: boolean; seq: number; }>
fence()
fence(
runId):Promise<void>
Defined in: packages/agentos/src/io/channels/meetings/stores/types.ts:151
The fence: from now on no payload of a content event is stored for the run.
Parameters
runId
string
Returns
Promise<void>
forget()?
optionalforget(runId):Promise<void>
Defined in: packages/agentos/src/io/channels/meetings/stores/types.ts:145
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>
purgePayloads()
purgePayloads(
runId):Promise<void>
Defined in: packages/agentos/src/io/channels/meetings/stores/types.ts:153
Removes the payload of every content event of the run; type, time and sequence stay.
Parameters
runId
string
Returns
Promise<void>
read()
read(
runId,fromSeq,limit?):Promise<MeetingEvent[]>
Defined in: packages/agentos/src/io/channels/meetings/stores/types.ts:149
The run's events after fromSeq, in sequence order, at most limit of them.
Parameters
runId
string
fromSeq
number
limit?
number
Returns
Promise<MeetingEvent[]>