Class: ConsolidationPipeline
Defined in: packages/agentos/src/memory/pipeline/consolidation/ConsolidationPipeline.ts:85
Constructors
Constructor
new ConsolidationPipeline(
config):ConsolidationPipeline
Defined in: packages/agentos/src/memory/pipeline/consolidation/ConsolidationPipeline.ts:92
Parameters
config
Returns
ConsolidationPipeline
Methods
getLastRunAt()
getLastRunAt():
number
Defined in: packages/agentos/src/memory/pipeline/consolidation/ConsolidationPipeline.ts:208
Get timestamp of last consolidation run.
Returns
number
run()
run():
Promise<ConsolidationResult>
Defined in: packages/agentos/src/memory/pipeline/consolidation/ConsolidationPipeline.ts:136
Run a single consolidation cycle.
Returns
Promise<ConsolidationResult>
start()
start():
void
Defined in: packages/agentos/src/memory/pipeline/consolidation/ConsolidationPipeline.ts:112
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/memory/pipeline/consolidation/ConsolidationPipeline.ts:126
Stop the periodic consolidation timer.
Returns
void