Struct UrlBackendConnector 

pub struct UrlBackendConnector {
    pub url: String,
    pub headers: Option<HashMap<String, String>>,
    pub connect_timeout: Duration,
}

Connect to a remote Streamable HTTP MCP URL (new connection each call).

Fields

url: String

headers: Option<HashMap<String, String>>

connect_timeout: Duration

Implementations

impl UrlBackendConnector

pub fn new( url: impl Into<String>, headers: Option<HashMap<String, String>>, ) -> Self

Create a URL connector.

pub fn with_connect_timeout(self, timeout: Duration) -> Self

Override connect timeout used by lazy session connect.

Trait Implementations

impl BackendConnector for UrlBackendConnector

fn connect_shared<'life0, 'async_trait>( &'life0 self, registry: Arc<UpstreamPeerRegistry>, ) -> Pin<Box<dyn Future<Output = Result<BackendRunningService>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connect using a shared fan-out registry (stdio / shared isolation).

fn connect_session<'life0, 'async_trait>( &'life0 self, slot: UpstreamPeerSlot, ) -> Pin<Box<dyn Future<Output = Result<BackendRunningService>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connect for one session with a 1:1 notify slot (URL / per-session).

fn connect_timeout(&self) -> Duration

Timeout used when awaiting lazy per-session connect.

impl Clone for UrlBackendConnector

fn clone(&self) -> UrlBackendConnector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UrlBackendConnector

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

Formats the value using the given formatter.