Class InMemoryStorageAdapter

In-memory storage adapter for AgentOS.

Provides a complete implementation of IStorageAdapter without any persistence. All data is stored in JavaScript Map and Array structures.

Use Cases:

Unit and integration testing
Development environments
Stateless sessions
CI/CD pipelines
Prototyping and demos

Characteristics:

Zero setup (no database required)
Extremely fast (no I/O)
Non-persistent (data lost on process exit)
Thread-safe in single-threaded environments

InMemoryStorageAdapter

Implements

Example

// Perfect for testing
const storage = new InMemoryStorageAdapter();
await storage.initialize();

const conversation = await storage.createConversation({
  id: 'test-conv',
  userId: 'test-user',
  createdAt: Date.now(),
  lastActivity: Date.now()
});

// No cleanup needed for tests
await storage.close();

Implements

IStorageAdapter

Index

Constructors

constructor

Methods

initialize close createConversation getConversation updateConversation deleteConversation listConversations storeMessage getMessage getMessages deleteMessage deleteMessagesForConversation getMessageCount getConversationTokenUsage

Constructors

constructor

new InMemoryStorageAdapter(): InMemoryStorageAdapter
Creates a new in-memory storage adapter.

No configuration needed since everything is in memory.

Returns InMemoryStorageAdapter
Example
```
const storage = new InMemoryStorageAdapter();
```
- Defined in core/storage/InMemoryStorageAdapter.ts:82

Methods

initialize

initialize(): Promise<void>
Initializes the storage adapter.

For in-memory adapter, this just sets the initialized flag.

Returns Promise<void>
Implementation of IStorageAdapter.initialize
- Defined in core/storage/InMemoryStorageAdapter.ts:93

close

close(): Promise<void>
Closes the storage adapter and clears all data.

Warning: This deletes all conversations and messages from memory.

Returns Promise<void>
Implementation of IStorageAdapter.close
- Defined in core/storage/InMemoryStorageAdapter.ts:104

createConversation

createConversation(conversation): Promise<IConversation>
Creates a new conversation.
Parameters
- conversation: IConversation
  Conversation to create
Returns Promise<IConversation>
The created conversation

Throws
If conversation with same ID already exists
Implementation of IStorageAdapter.createConversation
- Defined in core/storage/InMemoryStorageAdapter.ts:120

getConversation

getConversation(conversationId): Promise<null | IConversation>
Retrieves a conversation by ID.
Parameters
- conversationId: string
  Conversation ID
Returns Promise<null | IConversation>
The conversation or null
Implementation of IStorageAdapter.getConversation
- Defined in core/storage/InMemoryStorageAdapter.ts:141

updateConversation

updateConversation(conversationId, updates): Promise<IConversation>
Updates a conversation.
Parameters
- conversationId: string
  Conversation to update
- updates: Partial<IConversation>
  Fields to update
Returns Promise<IConversation>
Updated conversation

Throws
If conversation doesn't exist
Implementation of IStorageAdapter.updateConversation
- Defined in core/storage/InMemoryStorageAdapter.ts:156

deleteConversation

deleteConversation(conversationId): Promise<boolean>
Deletes a conversation and all its messages.
Parameters
- conversationId: string
  Conversation to delete
Returns Promise<boolean>
True if deleted, false if not found
Implementation of IStorageAdapter.deleteConversation
- Defined in core/storage/InMemoryStorageAdapter.ts:179

listConversations

listConversations(userId, options?): Promise<IConversation[]>
Lists conversations for a user.
Parameters
- userId: string
  User whose conversations to list
- Optional options: {
      limit?: number;
      offset?: number;
      agentId?: string;
  }
  Query options
  - Optional limit?: number
  - Optional offset?: number
  - Optional agentId?: string
Returns Promise<IConversation[]>
Array of conversations
Implementation of IStorageAdapter.listConversations
- Defined in core/storage/InMemoryStorageAdapter.ts:206

storeMessage

storeMessage(message): Promise<IConversationMessage>
Stores a message.
Parameters
- message: IConversationMessage
  Message to store
Returns Promise<IConversationMessage>
The stored message

Throws
If conversation doesn't exist
Implementation of IStorageAdapter.storeMessage
- Defined in core/storage/InMemoryStorageAdapter.ts:238

getMessage

getMessage(messageId): Promise<null | IConversationMessage>
Retrieves a message by ID.
Parameters
- messageId: string
  Message ID
Returns Promise<null | IConversationMessage>
The message or null
Implementation of IStorageAdapter.getMessage
- Defined in core/storage/InMemoryStorageAdapter.ts:267

getMessages

getMessages(conversationId, options?): Promise<IConversationMessage[]>
Retrieves messages for a conversation with filtering.
Parameters
- conversationId: string
  Conversation ID
- Optional options: IMessageQueryOptions
  Query options
Returns Promise<IConversationMessage[]>
Array of messages
Implementation of IStorageAdapter.getMessages
- Defined in core/storage/InMemoryStorageAdapter.ts:281

deleteMessage

deleteMessage(messageId): Promise<boolean>
Deletes a message.
Parameters
- messageId: string
  Message to delete
Returns Promise<boolean>
True if deleted
Implementation of IStorageAdapter.deleteMessage
- Defined in core/storage/InMemoryStorageAdapter.ts:322

deleteMessagesForConversation

deleteMessagesForConversation(conversationId): Promise<number>
Deletes all messages in a conversation.
Parameters
- conversationId: string
  Conversation whose messages to delete
Returns Promise<number>
Number of messages deleted
Implementation of IStorageAdapter.deleteMessagesForConversation
- Defined in core/storage/InMemoryStorageAdapter.ts:350

getMessageCount

getMessageCount(conversationId): Promise<number>
Counts messages in a conversation.
Parameters
- conversationId: string
  Conversation to count
Returns Promise<number>
Message count
Implementation of IStorageAdapter.getMessageCount
- Defined in core/storage/InMemoryStorageAdapter.ts:373

getConversationTokenUsage

getConversationTokenUsage(conversationId): Promise<ITokenUsage>
Calculates total token usage for a conversation.
Parameters
- conversationId: string
  Conversation to analyze
Returns Promise<ITokenUsage>
Aggregated token usage
Implementation of IStorageAdapter.getConversationTokenUsage
- Defined in core/storage/InMemoryStorageAdapter.ts:386

Class InMemoryStorageAdapter

Implements

Example

Implements

Index

Constructors

Methods

Constructors

constructor

Returns InMemoryStorageAdapter

Example

Methods

initialize

Returns Promise<void>

close

Returns Promise<void>

createConversation

Parameters

Returns Promise<IConversation>

Throws

getConversation

Parameters

Returns Promise<null | IConversation>

updateConversation

Parameters

Returns Promise<IConversation>

Throws

deleteConversation

Parameters

Returns Promise<boolean>

listConversations

Parameters

Optional limit?: number

Optional offset?: number

Optional agentId?: string

Returns Promise<IConversation[]>

storeMessage

Parameters

Returns Promise<IConversationMessage>

Throws

getMessage

Parameters

Returns Promise<null | IConversationMessage>

getMessages

Parameters

Returns Promise<IConversationMessage[]>

deleteMessage

Parameters

Returns Promise<boolean>

deleteMessagesForConversation

Parameters

Returns Promise<number>

getMessageCount

Parameters

Returns Promise<number>

getConversationTokenUsage

Parameters

Returns Promise<ITokenUsage>

Settings

Member Visibility

Theme

On This Page

`Optional` limit?: number

`Optional` offset?: number

`Optional` agentId?: string