Struct A2AClient 

pub struct A2AClient { /* private fields */ }

High-level A2A client for communicating with remote agents.

Implementations

impl A2AClient

pub fn new(base_url: &str) -> Self

Create a new A2A client for a remote agent.

pub fn with_http_client(base_url: &str, http: Client) -> Self

Create a client with a custom HTTP client.

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

Set authentication token.

pub async fn discover(&mut self) -> A2AResult<&AgentCard>

Discover the remote agent’s capabilities by fetching its Agent Card.

pub fn agent_card(&self) -> Option<&AgentCard>

Get the cached agent card (call discover() first).

pub async fn send_message(&self, request: SendMessageRequest) -> A2AResult<Task>

Send a message to the remote agent, creating or continuing a task.

pub async fn send_message_text(&self, text: &str) -> A2AResult<Task>

Convenience: send a simple text message.

pub async fn continue_task(&self, task_id: &str, text: &str) -> A2AResult<Task>

Continue an existing task with additional input.

pub async fn get_task(&self, task_id: &str) -> A2AResult<Task>

Get a task by its ID.

pub async fn list_tasks(&self, params: TaskQueryParams) -> A2AResult<Vec<Task>>

List tasks matching the given query parameters.

pub async fn cancel_task(&self, task_id: &str) -> A2AResult<Task>

Cancel a running task.

pub async fn send_streaming_message( &self, request: SendMessageRequest, ) -> A2AResult<TaskEventStream>

Send a streaming message — returns an SSE stream of task events.

The remote agent will stream back TaskEvents as it processes the message (state changes, partial artifacts, etc.).

pub async fn send_streaming_text( &self, text: &str, ) -> A2AResult<TaskEventStream>

Convenience: send a streaming text message.

pub async fn subscribe_task(&self, task_id: &str) -> A2AResult<TaskEventStream>

Subscribe to an existing task’s updates via SSE.

pub async fn create_push_notification( &self, config: &PushNotificationConfig, ) -> A2AResult<PushNotificationConfig>

Create a push notification configuration for a task.

pub async fn get_push_notification( &self, config_id: &str, task_id: &str, ) -> A2AResult<PushNotificationConfig>

Get a push notification configuration by ID.

pub async fn list_push_notifications( &self, task_id: &str, ) -> A2AResult<Vec<PushNotificationConfig>>

List push notification configurations for a task.

pub async fn delete_push_notification( &self, config_id: &str, task_id: &str, ) -> A2AResult<()>

Delete a push notification configuration.

pub async fn get_extended_agent_card(&self) -> A2AResult<AgentCard>

Get the extended agent card (post-authentication).

Trait Implementations

impl Clone for A2AClient

fn clone(&self) -> A2AClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for A2AClient

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

Formats the value using the given formatter.