Struct A2AClient 

pub struct A2AClient { /* private fields */ }

A2A HTTP Client for agent-to-agent communication

Implementations

impl A2AClient

pub fn new() -> Self

Create a new A2A client

pub fn with_auth(token: impl Into<String>) -> Self

Create a client with authentication token

pub fn set_auth_token(&mut self, token: impl Into<String>)

Set authentication token

pub async fn discover(&self, url: &str) -> Result<AgentCard, AppError>

Discover an agent at the given URL

pub async fn create_task( &self, url: &str, message: &str, ) -> Result<A2ATask, AppError>

Create a task on a remote agent

pub async fn create_task_with_request( &self, url: &str, task: CreateTaskRequest, ) -> Result<A2ATask, AppError>

Create a task with a structured remote contract.

pub async fn retry_task( &self, url: &str, task_id: &str, ) -> Result<A2ATask, AppError>

Retry an existing remote task.

pub async fn heartbeat_task( &self, url: &str, heartbeat: TaskHeartbeatRequest, ) -> Result<A2ATask, AppError>

Send a heartbeat/update for a leased remote task.

pub async fn list_task_artifacts( &self, url: &str, task_id: &str, ) -> Result<Vec<ArtifactManifestEntry>, AppError>

List artifact manifests for a task.

pub async fn fetch_task_artifact( &self, url: &str, task_id: &str, artifact_name: &str, ) -> Result<Artifact, AppError>

Fetch a specific artifact payload for a task.

pub async fn get_task_status( &self, url: &str, task_id: &str, ) -> Result<A2ATask, AppError>

Get task status

pub async fn cancel_task( &self, url: &str, task_id: &str, ) -> Result<A2ATask, AppError>

Cancel a task

Trait Implementations

impl Default for A2AClient

fn default() -> Self

Returns the “default value” for a type.