Skip to main content

Class: ObservationBuffer

Defined in: packages/agentos/src/memory/observation/ObservationBuffer.ts:41

Constructors​

Constructor​

new ObservationBuffer(config?): ObservationBuffer

Defined in: packages/agentos/src/memory/observation/ObservationBuffer.ts:48

Parameters​

config?​

Partial<ObservationBufferConfig>

Returns​

ObservationBuffer

Methods​

clear()​

clear(): void

Defined in: packages/agentos/src/memory/observation/ObservationBuffer.ts:105

Clear the buffer entirely.

Returns​

void

drain()​

drain(): BufferedMessage[]

Defined in: packages/agentos/src/memory/observation/ObservationBuffer.ts:79

Drain messages since last drain for observation processing. Returns the messages and marks them as consumed.

Returns​

BufferedMessage[]

getMessageCount()​

getMessageCount(): number

Defined in: packages/agentos/src/memory/observation/ObservationBuffer.ts:100

Total message count.

Returns​

number

getPendingTokens()​

getPendingTokens(): number

Defined in: packages/agentos/src/memory/observation/ObservationBuffer.ts:95

Unprocessed tokens since last drain.

Returns​

number

getTotalTokens()​

getTotalTokens(): number

Defined in: packages/agentos/src/memory/observation/ObservationBuffer.ts:90

Total accumulated tokens.

Returns​

number

push()​

push(role, content): boolean

Defined in: packages/agentos/src/memory/observation/ObservationBuffer.ts:58

Add a message to the buffer. Returns true if the buffer has reached activation threshold.

Parameters​

role​

"user" | "tool" | "system" | "assistant"

content​

string

Returns​

boolean

shouldActivate()​

shouldActivate(): boolean

Defined in: packages/agentos/src/memory/observation/ObservationBuffer.ts:71

Whether accumulated tokens since last drain exceed the threshold.

Returns​

boolean