Class ConsolidationPipeline

Index

Constructors

Methods

start stop run getLastRunAt

Constructors

constructor

new ConsolidationPipeline(config): ConsolidationPipeline
Parameters
- config: ConsolidationPipelineConfig
Returns ConsolidationPipeline
- Defined in src/memory/pipeline/consolidation/ConsolidationPipeline.ts:85

Methods

start

start(): void
Start the periodic consolidation timer.

Returns void
- Defined in src/memory/pipeline/consolidation/ConsolidationPipeline.ts:97

stop

stop(): void
Stop the periodic consolidation timer.

Returns void
- Defined in src/memory/pipeline/consolidation/ConsolidationPipeline.ts:108

run

run(): Promise<ConsolidationResult>
Run a single consolidation cycle.

Returns Promise<ConsolidationResult>
- Defined in src/memory/pipeline/consolidation/ConsolidationPipeline.ts:118

getLastRunAt

getLastRunAt(): number
Get timestamp of last consolidation run.

Returns number
- Defined in src/memory/pipeline/consolidation/ConsolidationPipeline.ts:172