Class: ObservationBuffer
Defined in: packages/agentos/src/cognition/memory/pipeline/observation/ObservationBuffer.ts:52
Constructors
Constructor
new ObservationBuffer(
config?):ObservationBuffer
Defined in: packages/agentos/src/cognition/memory/pipeline/observation/ObservationBuffer.ts:59
Parameters
config?
Partial<ObservationBufferConfig>
Returns
ObservationBuffer
Methods
clear()
clear():
void
Defined in: packages/agentos/src/cognition/memory/pipeline/observation/ObservationBuffer.ts:126
Clear the buffer entirely.
Returns
void
drain()
drain():
BufferedMessage[]
Defined in: packages/agentos/src/cognition/memory/pipeline/observation/ObservationBuffer.ts:100
Drain messages since last drain for observation processing. Returns the messages and marks them as consumed.
Returns
getMessageCount()
getMessageCount():
number
Defined in: packages/agentos/src/cognition/memory/pipeline/observation/ObservationBuffer.ts:121
Total message count.
Returns
number
getPendingTokens()
getPendingTokens():
number
Defined in: packages/agentos/src/cognition/memory/pipeline/observation/ObservationBuffer.ts:116
Unprocessed tokens since last drain.
Returns
number
getTotalTokens()
getTotalTokens():
number
Defined in: packages/agentos/src/cognition/memory/pipeline/observation/ObservationBuffer.ts:111
Total accumulated tokens.
Returns
number
push()
push(
role,content):boolean
Defined in: packages/agentos/src/cognition/memory/pipeline/observation/ObservationBuffer.ts:70
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/cognition/memory/pipeline/observation/ObservationBuffer.ts:87
Whether accumulated tokens OR messages since the last drain exceed their thresholds. The message-count path is what makes the observer fire in chat, where turns are far too small to ever reach the token threshold.
Returns
boolean