MemoryLiveAdapter

Implements TMemoryInstance

Live trading memory adapter with pluggable storage backend.

Features:

• Adapter pattern for swappable memory instance implementations
• Default backend: MemoryPersistInstance (file-system backed, survives restarts)
• Alternative backends: MemoryLocalInstance, MemoryDummyInstance
• Convenience methods: useLocal(), usePersist(), useDummy(), useMemoryAdapter()
• Memoized instances per (signalId, bucketName) pair; cleared via disposeSignal() from MemoryAdapter

Use this adapter for live trading memory storage.

Constructor

constructor();
Copy

Properties

MemoryFactory

MemoryFactory: any
Copy

getInstance

getInstance: any
Copy

disposeSignal

disposeSignal: (signalId: string) => void
Copy

Disposes all memoized instances for the given signalId. Called by MemoryAdapter when a signal is cancelled or closed.

writeMemory

writeMemory: <T extends object = object>(dto: { memoryId: string; value: T; signalId: string; bucketName: string; description: string; }) => Promise<void>
Copy

Write a value to memory.

searchMemory

searchMemory: <T extends object = object>(dto: { query: string; signalId: string; bucketName: string; settings?: SearchSettings; }) => Promise<{ memoryId: string; score: number; content: T; }[]>
Copy

Search memory using BM25 full-text scoring.

listMemory

listMemory: <T extends object = object>(dto: { signalId: string; bucketName: string; }) => Promise<{ memoryId: string; content: T; }[]>
Copy

List all entries in memory.

removeMemory

removeMemory: (dto: { memoryId: string; signalId: string; bucketName: string; }) => Promise<void>
Copy

Remove an entry from memory.

readMemory

readMemory: <T extends object = object>(dto: { memoryId: string; signalId: string; bucketName: string; }) => Promise<T>
Copy

Read a single entry from memory.

useLocal

useLocal: () => void
Copy

Switches to in-memory BM25 adapter. All data lives in process memory only.

usePersist

usePersist: () => void
Copy

Switches to file-system backed adapter (default). Data is persisted to ./dump/memory/<signalId>/<bucketName>/.

useDummy

useDummy: () => void
Copy

Switches to dummy adapter that discards all writes.

useMemoryAdapter

useMemoryAdapter: (Ctor: TMemoryInstanceCtor) => void
Copy

Switches to a custom memory adapter implementation.

clear

clear: () => void
Copy

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