Skip to main content

Class: InMemoryTranscriptStore

Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:188

Transcript turns in memory: for tests, single-process hosts and runs that are not kept.

Implements​

Constructors​

Constructor​

new InMemoryTranscriptStore(): InMemoryTranscriptStore

Returns​

InMemoryTranscriptStore

Methods​

append()​

append(turn): Promise<void>

Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:198

Adds an already numbered turn; a repeated (runId, seq) keeps the first copy. Rejects with FencedError once fenced.

Parameters​

turn​

TranscriptTurn

Returns​

Promise<void>

Implementation of​

ITranscriptStore.append


appendNext()​

appendNext(input): Promise<TranscriptTurn>

Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:207

Assigns the next seq and turnId for this run and stores the turn atomically, under the same anchor as the fence. Continues after the largest stored or allocated seq across sink instances. Optional for existing store implementers; required by MeetingTranscriptSink, which checks it at construction.

Parameters​

input​

TranscriptInput

Returns​

Promise<TranscriptTurn>

Implementation of​

ITranscriptStore.appendNext


drop()​

drop(runId): Promise<void>

Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:231

Alias for whole-run eviction after the retention grace.

Parameters​

runId​

string

Returns​

Promise<void>


fence()​

fence(runId): Promise<void>

Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:221

The fence: from now on the run takes no new turn.

Parameters​

runId​

string

Returns​

Promise<void>

Implementation of​

ITranscriptStore.fence


forget()​

forget(runId): Promise<void>

Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:189

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​

ITranscriptStore.forget


isFenced()​

isFenced(runId): Promise<boolean>

Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:224

Whether the run is fenced.

Parameters​

runId​

string

Returns​

Promise<boolean>

Implementation of​

ITranscriptStore.isFenced


purge()​

purge(runId): Promise<void>

Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:227

Removes the run's turns; the fence stays.

Parameters​

runId​

string

Returns​

Promise<void>

Implementation of​

ITranscriptStore.purge


read()​

read(runId, fromSeq, limit?): Promise<TranscriptTurn[]>

Defined in: packages/agentos/src/io/channels/meetings/stores/memory.ts:218

The run's turns after fromSeq, in order, at most limit of them.

Parameters​

runId​

string

fromSeq​

number

limit?​

number = 500

Returns​

Promise<TranscriptTurn[]>

Implementation of​

ITranscriptStore.read