PersistMeasureUtils

Utility class for managing external API response cache persistence.

Features:

• Memoized storage instances per cache bucket (aligned timestamp + symbol)
• Custom adapter support
• Atomic read/write operations
• Crash-safe cache state management

Used by Cache.file for persistent caching of external API responses.

Constructor

constructor();
Copy

Properties

PersistMeasureFactory

PersistMeasureFactory: any
Copy

getMeasureStorage

getMeasureStorage: any
Copy

readMeasureData

readMeasureData: (bucket: string, key: string) => Promise<MeasureData>
Copy

Reads cached measure data for a given bucket and key.

writeMeasureData

writeMeasureData: (data: MeasureData, bucket: string, key: string) => Promise<void>
Copy

Writes measure data to disk with atomic file writes.

removeMeasureData

removeMeasureData: (bucket: string, key: string) => Promise<void>
Copy

Marks a cached entry as removed (soft delete — file is kept on disk). After this call readMeasureData for the same key returns null.

Methods

usePersistMeasureAdapter

usePersistMeasureAdapter(Ctor: TPersistBaseCtor<string, MeasureData>): void;
Copy

Registers a custom persistence adapter.

listMeasureData

listMeasureData(bucket: string): AsyncGenerator<string>;
Copy

Async generator yielding all non-removed entity keys for a given bucket. Used by CacheFileInstance.clear() to iterate and soft-delete all entries.

clear

clear(): void;
Copy

Clears the memoized storage cache. Call this when process.cwd() changes between strategy iterations so new storage instances are created with the updated base path.

useJson

useJson(): void;
Copy

Switches to the default JSON persist adapter.

useDummy

useDummy(): void;
Copy

Switches to a dummy persist adapter that discards all writes.