Struct Connection 

pub struct Connection { /* private fields */ }

A configured server, connected on demand.

Implementations

impl Connection

pub fn new( entry: ServerEntry, cwd: PathBuf, agent_dir: PathBuf, on_tools: ToolsListener, readable_resources: Arc<dyn Fn(&str) -> bool + Send + Sync>, provider_token: Option<ProviderToken>, ) -> Arc<Connection>

A connection for entry, not yet connected, with OAuth credentials kept in agent_dir. Its callbacks:

• on_tools: learns of tool and resource changes
• readable_resources: tells whether the resource tools reach a server
• provider_token: reads the token of servers with auth.provider

pub fn oauth_url(&self) -> Option<&str>

The server URL when the server signs in with OAuth.

pub async fn sign_in(&self, prompt: &SignInPrompt) -> Result<(), AuthError>

Signs in to an OAuth server. The caller reconnects afterwards.

pub async fn remove_credentials(&self) -> Result<bool, McpError>

Removes the server’s stored OAuth credentials. Returns whether any were stored.

pub async fn sign_out(&self)

Disconnects after the stored credentials were removed.

pub async fn signed_in_elsewhere(&self) -> bool

Whether the server needs a sign-in and its stored credentials changed since it came to, as when another process signed in.

pub fn name(&self) -> &str

The server’s name.

pub fn entry(&self) -> &ServerEntry

The configured entry.

pub fn timeout(&self) -> Duration

The per-request timeout.

pub fn snapshot(&self) -> Snapshot

What it knows of its server.

pub fn state(&self) -> State

Where it stands.

pub fn readable_resources(&self) -> bool

Whether read_mcp_resource reaches this server.

pub async fn client(self: &Arc<Self>) -> Result<McpClient, McpError>

The connected client, connecting when needed.

pub async fn call_tool( self: &Arc<Self>, name: &str, args: Value, options: RequestOptions, ) -> Result<Value, McpError>

Calls one of the server’s tools. Not retried, since it may have run.

pub async fn read_resource( self: &Arc<Self>, uri: &str, options: RequestOptions, ) -> Result<Value, McpError>

Reads a resource.

pub async fn resources_page( self: &Arc<Self>, kind: ResourceKind, cursor: Option<String>, options: RequestOptions, ) -> Result<(Vec<Value>, Option<String>), McpError>

One page of resources or resource templates, with no templates for servers without the method.

pub async fn all_resources( self: &Arc<Self>, kind: ResourceKind, options: RequestOptions, ) -> Result<Vec<Value>, McpError>

Every resource or resource template, with no templates for servers without the method.

pub async fn reconnect(self: &Arc<Self>) -> Result<(), McpError>

Connects again.

pub async fn close(&self)

Shuts the connection down for good. A refresh in flight is awaited: the server may already have rotated the refresh token.