Enum ProxyEvent 

pub enum ProxyEvent {
    Request(Box<RequestEvent>),
    SessionStart(SessionStartEvent),
    SessionEnd(SessionEndEvent),
    Heartbeat(HeartbeatEvent),
    SchemaVersionCreated(SchemaVersionCreatedEvent),
}

All events flowing through the event bus.

Each variant represents a distinct lifecycle moment. Sinks match on the variant to decide what to process.

Variants

Request(Box<RequestEvent>)

An MCP request completed (success or error).

SessionStart(SessionStartEvent)

A new MCP session established via initialize handshake.

SessionEnd(SessionEndEvent)

A session was closed (clean transport disconnect).

Heartbeat(HeartbeatEvent)

Periodic health snapshot emitted by the health check loop.

SchemaVersionCreated(SchemaVersionCreatedEvent)

A new SchemaVersion was created inside the proxy’s SchemaManager. Emitted after pagination merge + change detection. Consumers (SQLite writer, cloud sink) persist or forward the version directly from the event — no secondary lookup required.

Trait Implementations

impl Clone for ProxyEvent

fn clone(&self) -> ProxyEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ProxyEvent

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

Formats the value using the given formatter.

impl Serialize for ProxyEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.