Struct GrpcTransport 

pub struct GrpcTransport { /* private fields */ }

gRPC transport for A2A clients.

Connects to a tonic-served gRPC endpoint and translates A2A method calls into gRPC RPCs with JSON payloads. Implements the Transport trait for use with crate::A2aClient.

Implementations

impl GrpcTransport

pub async fn connect( endpoint: impl Into<String>, ) -> Result<GrpcTransport, ClientError>

Connects to a gRPC endpoint with default configuration.

The endpoint should be an http:// or https:// URL.

Errors

Returns ClientError::Transport if the connection fails.

pub async fn connect_with_config( endpoint: impl Into<String>, config: GrpcTransportConfig, ) -> Result<GrpcTransport, ClientError>

Connects to a gRPC endpoint with custom configuration.

Errors

Returns ClientError::Transport if the connection fails.

pub fn endpoint(&self) -> &str

Returns the endpoint URL this transport targets.

Trait Implementations

impl Clone for GrpcTransport

fn clone(&self) -> GrpcTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GrpcTransport

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

Formats the value using the given formatter.

impl Transport for GrpcTransport

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.