io.a2a_preview.client

类 A2AClient

java.lang.Object

io.a2a_preview.client.A2AClient

public class A2AClient
extends java.lang.Object

A2A protocol client implementation

构造器概要

构造器

构造器和说明
A2AClient(java.lang.String baseUrl) Create a new A2A client

方法概要

限定符和类型	方法和说明
JSONRPCResponse	cancelTask(TaskIDParams params) Cancel a task
AgentCard	getAgentCard() Get agent card information
JSONRPCResponse	getTask(TaskQueryParams params) Get the status of a task
JSONRPCResponse	sendTask(TaskSendParams params) Send a task message to the agent
java.util.concurrent.CompletableFuture<java.lang.Void>	sendTaskStreaming(TaskSendParams params, StreamingEventListener listener) Send a task with streaming response

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

A2AClient

public A2AClient(java.lang.String baseUrl)

Create a new A2A client

参数:

baseUrl - the base URL of the A2A server

方法详细资料

sendTask

public JSONRPCResponse sendTask(TaskSendParams params)
                         throws java.lang.Exception

Send a task message to the agent

参数:

params - task send parameters

返回:

JSON-RPC response containing the task

抛出:

java.lang.Exception

getTask

public JSONRPCResponse getTask(TaskQueryParams params)
                        throws java.lang.Exception

Get the status of a task

参数:

params - task query parameters

返回:

JSON-RPC response containing the task

抛出:

java.lang.Exception

cancelTask

public JSONRPCResponse cancelTask(TaskIDParams params)
                           throws java.lang.Exception

Cancel a task

参数:

params - task ID parameters

返回:

JSON-RPC response containing the task

抛出:

java.lang.Exception

sendTaskStreaming

public java.util.concurrent.CompletableFuture<java.lang.Void> sendTaskStreaming(TaskSendParams params,
                                                                                StreamingEventListener listener)

Send a task with streaming response

参数:

params - task send parameters

listener - event listener for streaming updates

返回:

CompletableFuture that completes when streaming ends

getAgentCard

public AgentCard getAgentCard()

Get agent card information

返回:

the agent card