kotlin-sdk-server/io.modelcontextprotocol.kotlin.sdk.server/EventStore

EventStore

Interface for resumability support via event storage

Functions

abstract suspend fun getStreamIdForEventId(eventId: String): String?

Returns the stream ID associated with eventId, or null if the event is unknown. Default implementation is a no-op which disables extra validation during replay.

replayEventsAfter

abstract suspend fun replayEventsAfter(lastEventId: String, sender: suspend (eventId: String, message: JSONRPCMessage) -> Unit): String

Replays events after the specified event ID

storeEvent

abstract suspend fun storeEvent(streamId: String, message: JSONRPCMessage): String

Stores an event for later retrieval