Class ObservationBuffer

Index

Constructors

Methods

push shouldActivate drain getTotalTokens getPendingTokens getMessageCount clear

Constructors

constructor

new ObservationBuffer(config?): ObservationBuffer
Parameters
- Optional config: Partial<ObservationBufferConfig>
Returns ObservationBuffer
- Defined in src/memory/pipeline/observation/ObservationBuffer.ts:48

Methods

push

push(role, content): boolean
Add a message to the buffer. Returns true if the buffer has reached activation threshold.
Parameters
- role: "user" | "assistant" | "system" | "tool"
- content: string
Returns boolean
- Defined in src/memory/pipeline/observation/ObservationBuffer.ts:58

shouldActivate

shouldActivate(): boolean
Whether accumulated tokens since last drain exceed the threshold.

Returns boolean
- Defined in src/memory/pipeline/observation/ObservationBuffer.ts:71

drain

drain(): BufferedMessage[]
Drain messages since last drain for observation processing. Returns the messages and marks them as consumed.

Returns BufferedMessage[]
- Defined in src/memory/pipeline/observation/ObservationBuffer.ts:79

getTotalTokens

getTotalTokens(): number
Total accumulated tokens.

Returns number
- Defined in src/memory/pipeline/observation/ObservationBuffer.ts:90

getPendingTokens

getPendingTokens(): number
Unprocessed tokens since last drain.

Returns number
- Defined in src/memory/pipeline/observation/ObservationBuffer.ts:95

getMessageCount

getMessageCount(): number
Total message count.

Returns number
- Defined in src/memory/pipeline/observation/ObservationBuffer.ts:100

clear

clear(): void
Clear the buffer entirely.

Returns void
- Defined in src/memory/pipeline/observation/ObservationBuffer.ts:105