Struct HttpClient 

pub struct HttpClient { /* private fields */ }

HTTP client for interacting with the A2A protocol via ConnectRPC

Implementations

impl HttpClient

pub fn new(base_url: String) -> Self

Create a new HTTP client with the given base URL

pub fn with_auth(base_url: String, auth_token: String) -> Self

Create a new HTTP client with authentication

pub fn with_timeout(self, timeout: u64) -> Self

Set the timeout for requests

pub fn base_url(&self) -> &str

Get the base URL of the client

pub async fn get_agent_card(&self) -> Result<AgentCard, A2AError>

Fetch the agent card from the agent’s /agent-card endpoint (plain HTTP GET)

pub async fn get_extended_agent_card( &self, tenant: Option<String>, ) -> Result<AgentCard, A2AError>

Fetch the extended agent card using ConnectRPC

Trait Implementations

impl Transport for HttpClient

fn protocol(&self) -> &str

The wire protocol this transport speaks, matching an agent interface’s protocol_binding (e.g. "JSONRPC", "CONNECTRPC", "GRPC").

fn send_task_message<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, task_id: &'life1 str, message: &'life2 Message, session_id: Option<&'life3 str>, history_length: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

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

Send a message to a task

fn get_task<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, history_length: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

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

Get a task by ID

fn cancel_task<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

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

Cancel a task

fn set_task_push_notification<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 TaskPushNotificationConfig, ) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2AError>> + Send + 'async_trait>>

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

Set up push notifications for a task

fn get_task_push_notification<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2AError>> + Send + 'async_trait>>

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

Get push notification configuration for a task

fn list_tasks<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 ListTasksParams, ) -> Pin<Box<dyn Future<Output = Result<ListTasksResult, A2AError>> + Send + 'async_trait>>

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

List tasks with filtering and pagination (v1.0.0)

fn list_push_notification_configs<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskPushNotificationConfig>, A2AError>> + Send + 'async_trait>>

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

List all push notification configs for a task (v1.0.0)

fn get_push_notification_config<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 str, config_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2AError>> + Send + 'async_trait>>

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

Get a specific push notification config by ID (v1.0.0)

fn delete_push_notification_config<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 str, config_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), A2AError>> + Send + 'async_trait>>

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

Delete a specific push notification config (v1.0.0)

fn subscribe_to_task<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 str, _history_length: Option<u32>, _last_event_id: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<StreamEvent, A2AError>> + Send>>, A2AError>> + Send + 'async_trait>>

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

Subscribe to task updates (for streaming).