Struct ProxyHandler

pub struct ProxyHandler { /* private fields */ }

Expand description

A proxy handler that forwards requests to a client based on the server’s capabilities

Implementations§

Trait Implementations§

Returns a duplicate of the value. Read more

Performs copy-assignment from source. Read more

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

Returns the argument unchanged.

Converts to this type from a reference to the input type.

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Convert this service to a dynamic boxed service Read more

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

ProxyHandler

Struct ProxyHandler Copy item path

Implementations§

impl ProxyHandler

pub fn new(client: RunningService<RoleClient, ClientInfo>) -> Self

Trait Implementations§

impl Clone for ProxyHandler

fn clone(&self) -> ProxyHandler

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

impl ServerHandler for ProxyHandler

fn get_info(&self) -> ServerInfo

async fn list_tools( &self, request: PaginatedRequestParam, _context: RequestContext<RoleServer>, ) -> Result<ListToolsResult, Error>

async fn call_tool( &self, request: CallToolRequestParam, _context: RequestContext<RoleServer>, ) -> Result<CallToolResult, Error>

async fn list_resources( &self, request: PaginatedRequestParam, _context: RequestContext<RoleServer>, ) -> Result<ListResourcesResult, Error>

async fn read_resource( &self, request: ReadResourceRequestParam, _context: RequestContext<RoleServer>, ) -> Result<ReadResourceResult, Error>

async fn list_resource_templates( &self, request: PaginatedRequestParam, _context: RequestContext<RoleServer>, ) -> Result<ListResourceTemplatesResult, Error>

async fn list_prompts( &self, request: PaginatedRequestParam, _context: RequestContext<RoleServer>, ) -> Result<ListPromptsResult, Error>

async fn get_prompt( &self, request: GetPromptRequestParam, _context: RequestContext<RoleServer>, ) -> Result<GetPromptResult, Error>

async fn complete( &self, request: CompleteRequestParam, _context: RequestContext<RoleServer>, ) -> Result<CompleteResult, Error>

async fn on_progress(&self, notification: ProgressNotificationParam)

async fn on_cancelled(&self, notification: CancelledNotificationParam)

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

fn initialize( &self, request: InitializeRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<InitializeResult, ErrorData>> + Send

fn set_level( &self, request: SetLevelRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + Send

fn subscribe( &self, request: SubscribeRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + Send

fn unsubscribe( &self, request: UnsubscribeRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + Send

fn on_initialized(&self) -> impl Future<Output = ()> + Send

fn on_roots_list_changed(&self) -> impl Future<Output = ()> + Send

fn get_peer(&self) -> Option<Peer<RoleServer>>

fn set_peer(&mut self, peer: Peer<RoleServer>)

Auto Trait Implementations§

impl Freeze for ProxyHandler

impl !RefUnwindSafe for ProxyHandler

impl Send for ProxyHandler

impl Sync for ProxyHandler

impl Unpin for ProxyHandler

impl UnsafeUnpin for ProxyHandler

impl !UnwindSafe for ProxyHandler

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> DynClone for Twhere T: Clone,

fn __clone_box(&self, _: Private) -> *mut ()

impl<R, S> DynService<R> for Swhere R: ServiceRole, S: Service<R>,

fn handle_request( &self, request: <R as ServiceRole>::PeerReq, context: RequestContext<R>, ) -> Pin<Box<dyn Future<Output = Result<<R as ServiceRole>::Resp, ErrorData>> + Send + '_>>

fn handle_notification( &self, notification: <R as ServiceRole>::PeerNot, ) -> Pin<Box<dyn Future<Output = Result<(), ErrorData>> + Send + '_>>

fn get_peer(&self) -> Option<Peer<R>>

fn set_peer(&mut self, peer: Peer<R>)

fn get_info(&self) -> <R as ServiceRole>::Info

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<H> Service<RoleServer> for Hwhere H: ServerHandler,

async fn handle_request( &self, request: <RoleServer as ServiceRole>::PeerReq, context: RequestContext<RoleServer>, ) -> Result<<RoleServer as ServiceRole>::Resp, ErrorData>

async fn handle_notification( &self, notification: <RoleServer as ServiceRole>::PeerNot, ) -> Result<(), ErrorData>

fn get_peer(&self) -> Option<Peer<RoleServer>>

fn set_peer(&mut self, peer: Peer<RoleServer>)

fn get_info(&self) -> <RoleServer as ServiceRole>::Info

impl<S> ServiceExt<RoleServer> for Swhere S: Service<RoleServer>,

fn serve_with_ct<T, E, A>( self, transport: T, ct: CancellationToken, ) -> impl Future<Output = Result<RunningService<RoleServer, S>, E>> + Sendwhere T: IntoTransport<RoleServer, E, A>, E: Error + From<Error> + Send + Sync + 'static,

fn into_dyn(self) -> Box<dyn DynService<R>>

fn serve<T, E, A>( self, transport: T, ) -> impl Future<Output = Result<RunningService<R, Self>, E>> + Sendwhere T: IntoTransport<R, E, A>, E: Error + From<Error> + Send + Sync + 'static, Self: Sized,

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

Struct ProxyHandler

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> DynClone for T
where T: Clone,

impl<R, S> DynService<R> for S
where R: ServiceRole, S: Service<R>,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

impl<H> Service<RoleServer> for H
where H: ServerHandler,

impl<S> ServiceExt<RoleServer> for S
where S: Service<RoleServer>,

fn serve_with_ct<T, E, A>( self, transport: T, ct: CancellationToken, ) -> impl Future<Output = Result<RunningService<RoleServer, S>, E>> + Send
where T: IntoTransport<RoleServer, E, A>, E: Error + From<Error> + Send + Sync + 'static,

fn serve<T, E, A>( self, transport: T, ) -> impl Future<Output = Result<RunningService<R, Self>, E>> + Send
where T: IntoTransport<R, E, A>, E: Error + From<Error> + Send + Sync + 'static, Self: Sized,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<T> ErasedDestructor for T
where T: 'static,