Documentation / @agentick/core / InboxStorage
Interface: InboxStorage ​
Defined in: core/src/app/types.ts:341
Storage adapter for durable external message delivery.
External producers write messages to the inbox; sessions self-subscribe and process. The default MemoryInboxStorage is always-on with zero overhead until the first write. Swap to postgres/redis for durability.
Same pattern as SessionStore: interface in core, memory impl in core, external backends in their own packages.
Methods ​
markDone() ​
markDone(
sessionId,messageId):Promise<void>
Defined in: core/src/app/types.ts:347
Mark a message as done (processed). Idempotent.
Parameters ​
sessionId ​
string
messageId ​
string
Returns ​
Promise<void>
pending() ​
pending(
sessionId):Promise<InboxMessage[]>
Defined in: core/src/app/types.ts:345
Get all pending messages for a session (FIFO order).
Parameters ​
sessionId ​
string
Returns ​
Promise<InboxMessage[]>
sessionsWithPending() ​
sessionsWithPending():
Promise<string[]>
Defined in: core/src/app/types.ts:351
List session IDs that have pending messages.
Returns ​
Promise<string[]>
subscribe() ​
subscribe(
sessionId,cb): () =>void
Defined in: core/src/app/types.ts:349
Subscribe to new messages for a session. Returns unsubscribe function.
Parameters ​
sessionId ​
string
cb ​
() => void
Returns ​
():
void
Returns ​
void
write() ​
write(
sessionId,message):Promise<string>
Defined in: core/src/app/types.ts:343
Write a message to a session's inbox. Returns assigned message ID.
Parameters ​
sessionId ​
string
message ​
Returns ​
Promise<string>