Struct A2aClient 

pub struct A2aClient { /* private fields */ }

Unified A2A client.

Implementations

impl A2aClient

pub fn new_jsonrpc(base_url: Url) -> Self

Create a client using JSON-RPC transport.

pub fn new_rest(base_url: Url) -> Self

Create a client using REST transport.

pub fn with_bearer_token(self, token: &str) -> Self

Set a bearer token for authentication.

Returns a new client with the token applied to the active transport.

pub async fn discover(base_url: &str) -> Result<AgentCard, A2aError>

Discover an agent card from a well-known URL.

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

Send a message.

pub fn stream_message( &self, req: SendMessageRequest, ) -> Pin<Box<dyn Stream<Item = Result<StreamResponse, A2aError>> + Send>>

Stream a message (returns SSE events).

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

Get a task by ID.

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

List tasks.

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

Cancel a task.

pub fn subscribe_to_task( &self, req: SubscribeToTaskRequest, ) -> Pin<Box<dyn Stream<Item = Result<StreamResponse, A2aError>> + Send>>

Subscribe to task updates.

pub async fn set_push_config( &self, config: TaskPushNotificationConfig, ) -> Result<TaskPushNotificationConfig, A2aError>

Set push notification config.

pub async fn get_push_config( &self, req: GetTaskPushNotificationConfigRequest, ) -> Result<TaskPushNotificationConfig, A2aError>

Get push notification config.

pub async fn delete_push_config( &self, req: DeleteTaskPushNotificationConfigRequest, ) -> Result<(), A2aError>

Delete push notification config.

pub async fn list_push_configs( &self, req: ListTaskPushNotificationConfigsRequest, ) -> Result<ListTaskPushNotificationConfigsResponse, A2aError>

List push notification configs.

pub async fn get_authenticated_extended_card( &self, req: GetExtendedAgentCardRequest, ) -> Result<AgentCard, A2aError>

Get the authenticated extended agent card.