Graphorin API reference v0.1.0
Graphorin API reference / @graphorin/mcp / / EventStore
Interface: EventStore
Defined in: packages/mcp/src/event-store/types.ts:60
Persistence contract for resumable streaming sessions.
Implementations MUST:
- Assign a monotonically-increasing EventId per
(streamId)namespace atstoreEvent(...)time. - Replay every event whose id is greater than
lastEventId, in storage order, when replayEventsAfter is invoked. - Return the StreamId the replayed events belong to so the caller can correlate the replay with the originating stream.
Implementations MAY enforce a per-stream capacity (the default in-memory store keeps a fixed-size ring buffer); evicted events are unrecoverable and the next resume falls through to the configured resumeMode.
Stable
Methods
clearStream()
clearStream(streamId): Promise<void>;Defined in: packages/mcp/src/event-store/types.ts:64
Drop every entry for the supplied stream.
Parameters
| Parameter | Type |
|---|---|
streamId | string |
Returns
Promise<void>
replayEventsAfter()
replayEventsAfter(lastEventId, opts): Promise<string>;Defined in: packages/mcp/src/event-store/types.ts:62
Parameters
| Parameter | Type |
|---|---|
lastEventId | string |
opts | ReplayEventsAfterOptions |
Returns
Promise<string>
size()
size(): Promise<number>;Defined in: packages/mcp/src/event-store/types.ts:66
Snapshot helper for tests and the operator dashboard.
Returns
Promise<number>
storeEvent()
storeEvent(streamId, message): Promise<string>;Defined in: packages/mcp/src/event-store/types.ts:61
Parameters
| Parameter | Type |
|---|---|
streamId | string |
message | JsonRpcMessage |
Returns
Promise<string>