PersistRecentUtils

Utility class for managing recent signal persistence.

Features:

• Memoized storage instances per (symbol, strategyName, exchangeName, frameName) context
• Custom adapter support
• Atomic read/write operations
• Crash-safe recent signal state management

Used by RecentPersistBacktestUtils/RecentPersistLiveUtils for recent signal persistence.

Constructor

constructor();
Copy

Properties

PersistRecentFactory

PersistRecentFactory: any
Copy

getStorage

getStorage: any
Copy

createKeyParts

createKeyParts: any
Copy

readRecentData

readRecentData: (symbol: string, strategyName: string, exchangeName: string, frameName: string, backtest: boolean) => Promise<IPublicSignalRow>
Copy

Reads the latest persisted recent signal for a given context.

Returns null if no recent signal exists.

writeRecentData

writeRecentData: (signalRow: IPublicSignalRow, symbol: string, strategyName: string, exchangeName: string, frameName: string, backtest: boolean) => Promise<void>
Copy

Writes the latest recent signal to disk with atomic file writes.

Uses symbol as the entity ID within the per-context storage instance. Uses atomic writes to prevent corruption on crashes.

Methods

usePersistRecentAdapter

usePersistRecentAdapter(Ctor: TPersistBaseCtor<string, IPublicSignalRow>): void;
Copy

Registers a custom persistence adapter.

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. All future persistence writes will use JSON storage.

useDummy

useDummy(): void;
Copy

Switches to a dummy persist adapter that discards all writes. All future persistence writes will be no-ops.