Class: IndexPersistenceManager

Constructors

new IndexPersistenceManager()

new IndexPersistenceManager(adapter, options?): IndexPersistenceManager

Parameters

Returns

IndexPersistenceManager

Methods

flushAll()

flushAll(): Promise<FlushResult>

Flush all dirty indexes to storage.

Returns

Promise<FlushResult>

flushModel()

flushModel(modelName, namespace?): Promise<FlushResult>

Flush dirty indexes for a specific model.

Parameters

Returns

Promise<FlushResult>

getDirtyCount()

getDirtyCount(): number

Get the number of dirty entries.

Returns

number

getEpoch()

getEpoch(modelName, namespace?): number

Get the current epoch for a model.

Parameters

Returns

number

getMemoryLimit()

getMemoryLimit(): number

Get the configured memory limit.

Returns

number

getMemoryUsage()

getMemoryUsage(): number

Get current memory usage in bytes.

Returns

number

hasDirty()

hasDirty(): boolean

Check if there are any dirty indexes pending flush.

Returns

boolean

init()

init(): void

Initialize the persistence manager. Sets up periodic flush timer and shutdown handlers.

Returns

void

isStale()

isStale(modelName, namespace?): Promise<boolean>

Check if persisted indexes are stale (epoch mismatch).

Parameters

Returns

Promise<boolean>

loadEpoch()

loadEpoch(modelName, namespace?): Promise<EpochData>

Load epoch data to check for stale indexes.

Parameters

Returns

Promise<EpochData>

markFilterDirty()

markFilterDirty(modelName, namespace?): void

Mark a filter as dirty (needs persistence).

Parameters

Returns

void

markIndexDirty()

markIndexDirty(
   modelName, 
   field, 
   namespace?): void

Mark a sorted index as dirty (needs persistence).

Parameters

Returns

void

persistEpoch()

persistEpoch(modelName, namespace?): Promise<void>

Persist epoch data for stale detection.

Parameters

Returns

Promise<void>

registerFilter()

registerFilter(
   modelName, 
   filter, 
   namespace?): void

Register a filter for persistence tracking.

Parameters

Returns

void

registerSortedIndex()

registerSortedIndex(
   modelName, 
   field, 
   index, 
   namespace?): void

Register a sorted index for persistence tracking.

Parameters

Returns

void

removeFromMemory()

removeFromMemory(
   modelName, 
   field, 
   namespace?): void

Remove an entry from memory tracking.

Parameters

Returns

void

scheduleFlush()

scheduleFlush(intervalMs): void

Schedule periodic flush.

Parameters

Returns

void

setupShutdownHandlers()

setupShutdownHandlers(): void

Setup process shutdown handlers.

Returns

void

shutdown()

shutdown(): Promise<void>

Shutdown the persistence manager. Flushes pending changes and cleans up timers.

Returns

Promise<void>

touchEntry()

touchEntry(
   modelName, 
   field, 
   namespace?): void

Mark an entry as recently accessed (for LRU ordering).

Parameters

Returns

void

trackFilterMemory()

trackFilterMemory(
   modelName, 
   filter, 
   namespace?): void

Track memory usage for a filter.

Parameters

Returns

void

trackIndexMemory()

trackIndexMemory(
   modelName, 
   field, 
   index, 
   namespace?): void

Track memory usage for a sorted index.

Parameters

Returns

void