Struct JsonRpcTransport 

pub struct JsonRpcTransport { /* private fields */ }

JSON-RPC 2.0 transport: HTTP POST to a single endpoint.

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

Implementations

impl JsonRpcTransport

pub fn new(endpoint: impl Into<String>) -> Result<JsonRpcTransport, ClientError>

Creates a new transport targeting the given endpoint URL.

The endpoint is typically the url field from an a2a_protocol_types::AgentCard.

Errors

Returns ClientError::InvalidEndpoint if the URL is malformed.

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

Creates a new transport with a custom request timeout.

Errors

Returns ClientError::InvalidEndpoint if the URL is malformed.

pub fn with_timeouts( endpoint: impl Into<String>, request_timeout: Duration, stream_connect_timeout: Duration, ) -> Result<JsonRpcTransport, 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( endpoint: impl Into<String>, request_timeout: Duration, stream_connect_timeout: Duration, connection_timeout: Duration, ) -> Result<JsonRpcTransport, 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 endpoint(&self) -> &str

Returns the endpoint URL this transport targets.

Trait Implementations

impl Clone for JsonRpcTransport

fn clone(&self) -> JsonRpcTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JsonRpcTransport

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

Formats the value using the given formatter.

impl Transport for JsonRpcTransport

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.