Class: ConsolidationPipeline
Defined in: packages/agentos/src/cognition/memory/pipeline/consolidation/ConsolidationPipeline.ts:93
Constructors
Constructor
new ConsolidationPipeline(
config):ConsolidationPipeline
Defined in: packages/agentos/src/cognition/memory/pipeline/consolidation/ConsolidationPipeline.ts:101
Parameters
config
Returns
ConsolidationPipeline
Methods
getLastRunAt()
getLastRunAt():
number
Defined in: packages/agentos/src/cognition/memory/pipeline/consolidation/ConsolidationPipeline.ts:242
Get timestamp of last consolidation run.
Returns
number
run()
run():
Promise<ConsolidationResult>
Defined in: packages/agentos/src/cognition/memory/pipeline/consolidation/ConsolidationPipeline.ts:160
Run a single consolidation cycle.
Returns
Promise<ConsolidationResult>
start()
start():
void
Defined in: packages/agentos/src/cognition/memory/pipeline/consolidation/ConsolidationPipeline.ts:121
Start the periodic consolidation timer.
The timer is .unref()'d so it does NOT keep the Node event loop
alive on its own. Long-running agents keep the process alive
through their own mechanisms (HTTP server, message bus, etc.);
short-lived contexts (benches, scripts) can exit cleanly once
their meaningful work completes. Callers that need a guaranteed
consolidation cycle before shutdown should call runConsolidation()
directly or trigger it via CognitiveMemoryManager.runConsolidation.
Returns
void
stop()
stop():
void
Defined in: packages/agentos/src/cognition/memory/pipeline/consolidation/ConsolidationPipeline.ts:140
Stop the periodic consolidation timer.
Returns
void
waitForIdle()
waitForIdle():
Promise<void>
Defined in: packages/agentos/src/cognition/memory/pipeline/consolidation/ConsolidationPipeline.ts:151
Wait for every consolidation cycle admitted before or during the drain. Call stop first when shutting down to prevent new timer cycles.
Returns
Promise<void>