Struct HttpA2AClient 

pub struct HttpA2AClient { /* private fields */ }

HTTP-based implementation of the A2A client protocol.

Uses reqwest to make real HTTP calls to remote agents’ A2A endpoints.

Implementations

impl HttpA2AClient

pub fn new() -> PunchResult<Self>

Create a new HTTP A2A client with the default 30-second timeout.

pub fn with_timeout(timeout: Duration) -> PunchResult<Self>

Create a new HTTP A2A client with a custom timeout.

pub fn build_url(base_url: &str, path: &str) -> String

Build the full URL for an A2A endpoint on a remote agent.

Trait Implementations

impl A2AClient for HttpA2AClient

fn discover<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, ) -> Pin<Box<dyn Future<Output = PunchResult<AgentCard>> + Send + 'async_trait>>

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

Fetch a remote agent’s card from its well-known URL.

fn send_task<'life0, 'life1, 'async_trait>( &'life0 self, agent: &'life1 AgentCard, task: A2ATask, ) -> Pin<Box<dyn Future<Output = PunchResult<A2ATask>> + Send + 'async_trait>>

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

Send a task to a remote agent via HTTP POST.

fn get_task_status<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, agent: &'life1 AgentCard, task_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = PunchResult<A2ATaskStatus>> + Send + 'async_trait>>

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

Get the status of a task on a remote agent via HTTP GET.

fn cancel_task<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, agent: &'life1 AgentCard, task_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = PunchResult<()>> + Send + 'async_trait>>

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

Cancel a task on a remote agent via HTTP POST.

impl Default for HttpA2AClient

fn default() -> Self

Returns the “default value” for a type.