Struct HttpClient 

pub struct HttpClient { /* private fields */ }

reqwest-backed HttpConnector.

Implementations

impl HttpClient

pub fn new( client: Client, base_url: String, auth: Arc<dyn HttpAuthProvider>, ) -> Result<Self, HttpConnectorError>

Construct a client. LAZY: parses base_url but contacts no backend (CF-2).

Errors

Returns HttpConnectorError::Backend when base_url is unparseable or the reqwest client cannot be built. The error message does NOT echo the URL.

pub fn with_config( client: Client, base_url: String, auth: Arc<dyn HttpAuthProvider>, http_config: HttpConfig, ) -> Result<Self, HttpConnectorError>

Construct a client with an explicit HttpConfig. LAZY (CF-2).

Errors

As HttpClient::new.

pub fn with_request_policy(self, policy: Arc<dyn RequestPolicy>) -> Self

Attach the E1 crate::policy::RequestPolicy consulted before every outbound request (Phase 128).

Cheap clone-with-builder, the same shape as HttpCodeExecutor::with_inbound_token. Neither HttpClient::new nor HttpClient::with_config changed signature.

pub fn from_config( base_url: String, auth: Arc<dyn HttpAuthProvider>, http_config: HttpConfig, ) -> Result<Self, HttpConnectorError>

Build a client from an HttpConfig, constructing the reqwest client with the configured timeout, user-agent, and default headers. LAZY (CF-2).

Errors

As HttpClient::new.

Trait Implementations

impl HttpConnector for HttpClient

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, operation: &'life1 Operation, args: &'life2 Value, ) -> Pin<Box<dyn Future<Output = Result<Value, HttpConnectorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute operation with the caller-supplied args (a JSON object whose keys map to path / query / header / body parameters) and return the response body as a serde_json::Value.

fn execute_for_tool<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tool: &'life1 str, operation: &'life2 Operation, args: &'life3 Value, ) -> Pin<Box<dyn Future<Output = Result<Value, HttpConnectorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Execute operation on behalf of the MCP tool named tool (Phase 128 E1).

fn has_request_policy(&self) -> bool

Whether this connector consults an E1 policy before sending (Phase 128).

fn governed( &self, policy: Arc<dyn RequestPolicy>, ) -> Option<Arc<dyn HttpConnector>>

A clone of this connector that consults policy before every outbound request (Phase 128 E1), or None when the implementation cannot host one.

fn base_url(&self) -> &str

The configured base URL (analog of SqlConnector::dialect()).