Struct EventManager

pub struct EventManager { /* private fields */ }

Handles SSE event processing and broadcasting to connected clients

This struct manages the broadcasting of events to multiple SSE clients using a Tokio broadcast channel. It provides methods for sending different types of events and handling SSE connections.

Implementations

impl EventManager

pub fn new(capacity: usize) -> Self

Create a new EventManager with the specified channel capacity

pub fn subscribe(&self) -> Receiver<SSEMessage>

Subscribe to events

pub fn send_tool_response( &self, request_id: &str, _server_id: &str, _tool_name: &str, data: Value, )

Send a tool response event using JSON-RPC format

pub fn send_tool_error( &self, request_id: &str, server_id: &str, tool_name: &str, error: &str, )

Send a tool error event using JSON-RPC format

pub fn send_server_status( &self, server_name: &str, server_id: &str, status: &str, )

Send a server status update event

pub fn send_notification(&self, title: &str, message: &str, level: &str)

Send a notification event

pub fn format_sse_message(message: &SSEMessage) -> Bytes

Format an SSEMessage for the wire

Trait Implementations

impl Clone for EventManager

fn clone(&self) -> EventManager

Returns a copy of the value.

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

Performs copy-assignment from source.