Graphorin API reference v0.1.0

---

Graphorin API reference / @graphorin/mcp / / InMemoryEventStore

Class: InMemoryEventStore

Defined in: packages/mcp/src/event-store/in-memory.ts:44

Default EventStore implementation. Keeps a per-stream fixed-size ring buffer of recent events.

Stable

Implements

• EventStore

Constructors

Constructor

new InMemoryEventStore(opts?): InMemoryEventStore;

Defined in: packages/mcp/src/event-store/in-memory.ts:50

Parameters

Parameter	Type
opts	InMemoryEventStoreOptions

Returns

InMemoryEventStore

Methods

clearStream()

clearStream(streamId): Promise<void>;

Defined in: packages/mcp/src/event-store/in-memory.ts:99

Drop every entry for the supplied stream.

Parameters

Parameter	Type
streamId	string

Returns

Promise<void>

Implementation of

EventStore.clearStream

---

eviction()

eviction(streamId): number;

Defined in: packages/mcp/src/event-store/in-memory.ts:59

Per-stream eviction counter snapshot for tests + metrics.

Parameters

Parameter	Type
streamId	string

Returns

number

---

replayEventsAfter()

replayEventsAfter(lastEventId, opts): Promise<string>;

Defined in: packages/mcp/src/event-store/in-memory.ts:78

Parameters

Parameter	Type
lastEventId	string
opts	ReplayEventsAfterOptions

Returns

Promise<string>

Implementation of

EventStore.replayEventsAfter

---

size()

size(): Promise<number>;

Defined in: packages/mcp/src/event-store/in-memory.ts:104

Snapshot helper for tests and the operator dashboard.

Returns

Promise<number>

Implementation of

EventStore.size

---

storeEvent()

storeEvent(streamId, message): Promise<string>;

Defined in: packages/mcp/src/event-store/in-memory.ts:63

Parameters

Parameter	Type
streamId	string
message	JsonRpcMessage

Returns

Promise<string>

Implementation of

EventStore.storeEvent