Struct InMemoryEventStore 

pub struct InMemoryEventStore { /* private fields */ }

Available on crate feature streamable-http and non-WebAssembly only.

In-memory event store implementation.

Implements this module’s three-method EventStore trait — NOT the six-method crate::shared::event_store::EventStore, and NOT the same-named crate::shared::event_store::InMemoryEventStore (both spans, not links: that module is gated behind v1-compat while this doc is not).

Public path

This type is reachable at pmcp::server::streamable_http_server::InMemoryEventStore and the example below exists to PIN that path: it is the concrete type the public StreamableHttpServerConfig::event_store field takes, so moving or re-exporting it elsewhere would be a MAJOR semver break. Phase 117 gates v1 surface without changing where any of it is reachable from on the default (v1-compat) build, and this doctest fails to compile if that stops being true.

The ungated half pins the TYPE PATH, which is public API on both feature sets (see the EventStore trait doc for why removing it is a 3.0 change):

use pmcp::server::streamable_http_server::InMemoryEventStore;
use std::sync::Arc;

let store = Arc::new(InMemoryEventStore::default());
assert_eq!(Arc::strong_count(&store), 1);

The v1-compat half pins the CONFIG WIRING, which is gated — this example does not compile on --no-default-features --features full-v2, and that is the severance being asserted rather than a bug:

use pmcp::server::streamable_http_server::{InMemoryEventStore, StreamableHttpServerConfig};
use std::sync::Arc;

let store = Arc::new(InMemoryEventStore::default());
let config = StreamableHttpServerConfig {
    event_store: Some(Arc::clone(&store)),
    ..Default::default()
};
assert!(config.event_store.is_some());

Trait Implementations

impl Debug for InMemoryEventStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InMemoryEventStore

fn default() -> Self

Returns the “default value” for a type.

impl EventStore for InMemoryEventStore

fn store_event<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, stream_id: &'life1 str, event_id: &'life2 str, message: &'life3 TransportMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Store an event for later retrieval

fn replay_events_after<'life0, 'life1, 'async_trait>( &'life0 self, last_event_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, TransportMessage)>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Replay events after a given event ID

fn get_stream_for_event<'life0, 'life1, 'async_trait>( &'life0 self, event_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get stream ID for an event ID