Struct RestTransport 

pub struct RestTransport { /* private fields */ }

REST transport: HTTP verbs mapped to REST paths.

Create via RestTransport::new or let crate::ClientBuilder construct one from the agent card.

Implementations

impl RestTransport

pub fn new(base_url: impl Into<String>) -> Result<RestTransport, ClientError>

Creates a new transport using base_url as the root URL.

Errors

Returns ClientError::InvalidEndpoint if the URL is malformed.

pub fn with_timeout( base_url: impl Into<String>, request_timeout: Duration, ) -> Result<RestTransport, ClientError>

Creates a new transport with a custom request timeout.

Errors

Returns ClientError::InvalidEndpoint if the URL is malformed.

pub fn with_timeouts( base_url: impl Into<String>, request_timeout: Duration, stream_connect_timeout: Duration, ) -> Result<RestTransport, ClientError>

Creates a new transport with separate request and stream connect timeouts.

Uses the default TCP connection timeout (10 seconds).

Errors

Returns ClientError::InvalidEndpoint if the URL is malformed.

pub fn with_all_timeouts( base_url: impl Into<String>, request_timeout: Duration, stream_connect_timeout: Duration, connection_timeout: Duration, ) -> Result<RestTransport, ClientError>

Creates a new transport with all timeout parameters.

connection_timeout is applied to the underlying TCP connector (DNS + handshake), preventing indefinite hangs when the server is unreachable.

Errors

Returns ClientError::InvalidEndpoint if the URL is malformed.

pub fn base_url(&self) -> &str

Returns the base URL this transport targets.

Trait Implementations

impl Clone for RestTransport

fn clone(&self) -> RestTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RestTransport

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

Formats the value using the given formatter.

impl Transport for RestTransport

fn send_request<'a>( &'a self, method: &'a str, params: Value, extra_headers: &'a HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = Result<Value, ClientError>> + Send + 'a>>

Sends a non-streaming JSON-RPC or REST request.

fn send_streaming_request<'a>( &'a self, method: &'a str, params: Value, extra_headers: &'a HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = Result<EventStream, ClientError>> + Send + 'a>>

Sends a streaming request and returns an EventStream.