Class InMemoryTranscriptStore

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

Implements

ITranscriptStore

Index

Constructors

Methods

forget append appendNext read fence isFenced purge drop

Constructors

constructor

new InMemoryTranscriptStore(): InMemoryTranscriptStore
Returns InMemoryTranscriptStore

Methods

forget

forget(runId): Promise<void>
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
- Defined in src/io/channels/meetings/stores/memory.ts:189

append

append(turn): Promise<void>
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
- Defined in src/io/channels/meetings/stores/memory.ts:198

appendNext

appendNext(input): Promise<TranscriptTurn>
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
- Defined in src/io/channels/meetings/stores/memory.ts:207

read

read(runId, fromSeq, limit?): Promise<TranscriptTurn[]>
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
- Defined in src/io/channels/meetings/stores/memory.ts:218

fence

fence(runId): Promise<void>
The fence: from now on the run takes no new turn.
Parameters
- runId: string
Returns Promise<void>
Implementation of ITranscriptStore.fence
- Defined in src/io/channels/meetings/stores/memory.ts:221

isFenced

isFenced(runId): Promise<boolean>
Whether the run is fenced.
Parameters
- runId: string
Returns Promise<boolean>
Implementation of ITranscriptStore.isFenced
- Defined in src/io/channels/meetings/stores/memory.ts:224

purge

purge(runId): Promise<void>
Removes the run's turns; the fence stays.
Parameters
- runId: string
Returns Promise<void>
Implementation of ITranscriptStore.purge
- Defined in src/io/channels/meetings/stores/memory.ts:227

drop

drop(runId): Promise<void>
Alias for whole-run eviction after the retention grace.
Parameters
- runId: string
Returns Promise<void>
- Defined in src/io/channels/meetings/stores/memory.ts:231