Struct BackendNotificationBridge 

pub struct BackendNotificationBridge { /* private fields */ }

Client-side handler used when the proxy connects to a backend MCP server.

Implementations

impl BackendNotificationBridge

pub fn new(info: ClientConfig, target: NotifyTarget) -> Self

Create a bridge with the given client info and notify target.

pub fn with_default_info(upstream_peers: Arc<UpstreamPeerRegistry>) -> Self

Shared-backend bridge (fan-out / routed progress).

pub fn for_session(slot: UpstreamPeerSlot) -> Self

Per-session bridge (1:1 notify to UpstreamPeerSlot).

pub fn upstream_peers(&self) -> Option<&Arc<UpstreamPeerRegistry>>

Shared upstream peer registry when target is NotifyTarget::Shared.

pub fn session_slot(&self) -> Option<&UpstreamPeerSlot>

Session peer slot when target is NotifyTarget::Session.

Trait Implementations

impl ClientHandler for BackendNotificationBridge

fn get_info(&self) -> ClientConfig

async fn on_resource_updated( &self, params: ResourceUpdatedNotificationParam, _context: NotificationContext<RoleClient>, )

async fn on_resource_list_changed( &self, _context: NotificationContext<RoleClient>, )

async fn on_tool_list_changed(&self, _context: NotificationContext<RoleClient>)

async fn on_prompt_list_changed( &self, _context: NotificationContext<RoleClient>, )

async fn on_logging_message( &self, params: LoggingMessageNotificationParam, _context: NotificationContext<RoleClient>, )

async fn on_task_status( &self, params: TaskStatusNotificationParams, _context: NotificationContext<RoleClient>, )

async fn on_progress( &self, params: ProgressNotificationParam, _context: NotificationContext<RoleClient>, )

fn ping( &self, context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn create_message( &self, params: CreateMessageRequestParams, context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<CreateMessageResult, ErrorData>> + MaybeSendFuture

fn list_roots( &self, context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<ListRootsResult, ErrorData>> + MaybeSendFuture

fn create_elicitation( &self, request: ElicitRequestParams, context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<ElicitResult, ErrorData>> + MaybeSendFuture

Handle an elicitation request from a server asking for user input.

fn on_custom_request( &self, request: CustomRequest, context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<CustomResult, ErrorData>> + MaybeSendFuture

fn on_cancelled( &self, params: CancelledNotificationParam, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_subscriptions_acknowledged( &self, params: SubscriptionsAcknowledgedNotificationParams, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_custom_notification( &self, notification: CustomNotification, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture

impl Clone for BackendNotificationBridge

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackendNotificationBridge

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

Formats the value using the given formatter.