StorageLiveAdapter

Implements IStorageUtils

Live trading storage adapter with pluggable storage backend.

Features:

• Adapter pattern for swappable storage implementations
• Default adapter: StoragePersistLiveUtils (persistent storage)
• Alternative adapters: StorageMemoryLiveUtils, StorageDummyLiveUtils
• Convenience methods: usePersist(), useMemory(), useDummy()

Constructor

constructor();
Copy

Properties

_signalLiveFactory

_signalLiveFactory: any
Copy

Factory producing the active storage utils instance

getInstance

getInstance: any
Copy

Lazily constructs the storage utils from the registered factory and memoizes the result via singleshot.

The instance is built on the first call and cached for all subsequent calls. Reset via clear() so the next call rebuilds from the current factory.

handleOpened

handleOpened: (tick: IStrategyTickResultOpened) => Promise<void>
Copy

Handles signal opened event. Proxies call to the underlying storage adapter.

handleClosed

handleClosed: (tick: IStrategyTickResultClosed) => Promise<void>
Copy

Handles signal closed event. Proxies call to the underlying storage adapter.

handleScheduled

handleScheduled: (tick: IStrategyTickResultScheduled) => Promise<void>
Copy

Handles signal scheduled event. Proxies call to the underlying storage adapter.

handleCancelled

handleCancelled: (tick: IStrategyTickResultCancelled) => Promise<void>
Copy

Handles signal cancelled event. Proxies call to the underlying storage adapter.

findById

findById: (id: string) => Promise<IStorageSignalRow>
Copy

Finds a signal by its ID. Proxies call to the underlying storage adapter.

list

list: () => Promise<IStorageSignalRow[]>
Copy

Lists all stored signals. Proxies call to the underlying storage adapter.

handleActivePing

handleActivePing: (event: ActivePingContract) => Promise<void>
Copy

Handles active ping event for opened signals. Updates updatedAt for the signal if it is currently opened.

handleSchedulePing

handleSchedulePing: (event: SchedulePingContract) => Promise<void>
Copy

Handles schedule ping event for scheduled signals. Updates updatedAt for the signal if it is currently scheduled.

useStorageAdapter

useStorageAdapter: (Ctor: TStorageUtilsCtor) => void
Copy

Sets the storage adapter constructor. All future storage operations will use this adapter.

useDummy

useDummy: () => void
Copy

Switches to dummy storage adapter. All future storage writes will be no-ops.

usePersist

usePersist: () => void
Copy

Switches to persistent storage adapter (default). Signals will be persisted to disk.

useMemory

useMemory: () => void
Copy

Switches to in-memory storage adapter. Signals will be stored in memory only.

clear

clear: () => void
Copy

Clears the memoized utils instance. Call this when process.cwd() changes between strategy iterations so a new instance is created with the updated base path.