Struct A2AClient 

pub struct A2AClient { /* private fields */ }

HTTP client for discovery, unary calls, and SSE streams against a remote agent.

Implementations

impl A2AClient

pub fn new(base_url: &str) -> Result<Self, A2AError>

Create a client with default configuration and a default reqwest client.

pub fn with_config( base_url: &str, config: A2AClientConfig, ) -> Result<Self, A2AError>

Create a client with explicit SDK configuration.

pub fn with_http_client( base_url: &str, client: Client, config: A2AClientConfig, ) -> Result<Self, A2AError>

Create a client with an explicit reqwest client and SDK configuration.

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

Discover the remote agent card, using the discovery cache when fresh.

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

Refresh the remote agent card and replace any cached copy.

pub async fn send_message( &self, request: SendMessageRequest, ) -> Result<SendMessageResponse, A2AError>

Invoke SendMessage over the server’s preferred unary transport.

pub async fn send_streaming_message( &self, request: SendMessageRequest, ) -> Result<A2AClientStream, A2AError>

Invoke SendStreamingMessage over HTTP+JSON SSE.

pub async fn get_task(&self, request: GetTaskRequest) -> Result<Task, A2AError>

Fetch a task by identifier.

pub async fn list_tasks( &self, request: ListTasksRequest, ) -> Result<ListTasksResponse, A2AError>

List tasks using the server’s preferred unary transport.

pub async fn cancel_task( &self, request: CancelTaskRequest, ) -> Result<Task, A2AError>

Request cancellation of a task.

pub async fn get_extended_agent_card( &self, request: GetExtendedAgentCardRequest, ) -> Result<AgentCard, A2AError>

Fetch the extended agent card when the remote agent advertises it.

pub async fn create_task_push_notification_config( &self, request: TaskPushNotificationConfig, ) -> Result<TaskPushNotificationConfig, A2AError>

Create or replace a push-notification configuration for a task.

pub async fn get_task_push_notification_config( &self, request: GetTaskPushNotificationConfigRequest, ) -> Result<TaskPushNotificationConfig, A2AError>

Fetch a single push-notification configuration by identifier.

pub async fn list_task_push_notification_configs( &self, request: ListTaskPushNotificationConfigsRequest, ) -> Result<ListTaskPushNotificationConfigsResponse, A2AError>

List push-notification configurations for a task.

pub async fn delete_task_push_notification_config( &self, request: DeleteTaskPushNotificationConfigRequest, ) -> Result<(), A2AError>

Delete a push-notification configuration by identifier.

pub async fn subscribe_to_task( &self, request: SubscribeToTaskRequest, ) -> Result<A2AClientStream, A2AError>

Subscribe to task updates over HTTP+JSON SSE.

Trait Implementations

impl Debug for A2AClient

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

Formats the value using the given formatter.