Package org.a2aproject.sdk.grpc

Class A2AServiceGrpc.A2AServiceStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<A2AServiceGrpc.A2AServiceStub>
org.a2aproject.sdk.grpc.A2AServiceGrpc.A2AServiceStub
Enclosing class:
A2AServiceGrpc
public static final class A2AServiceGrpc.A2AServiceStub extends io.grpc.stub.AbstractAsyncStub<A2AServiceGrpc.A2AServiceStub>
A stub to allow clients to do asynchronous rpc calls to service A2AService. 
 Provides operations for interacting with agents using the A2A protocol.

  • Method Details

    • build

      protected A2AServiceGrpc.A2AServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<A2AServiceGrpc.A2AServiceStub>

    • sendMessage

      public void sendMessage(SendMessageRequest request, io.grpc.stub.StreamObserver<SendMessageResponse> responseObserver)
       Sends a message to an agent.

    • sendStreamingMessage

      public void sendStreamingMessage(SendMessageRequest request, io.grpc.stub.StreamObserver<StreamResponse> responseObserver)
       Sends a streaming message to an agent, allowing for real-time interaction and status updates.
 Streaming version of `SendMessage`

    • getTask

      public void getTask(GetTaskRequest request, io.grpc.stub.StreamObserver<Task> responseObserver)
       Gets the latest state of a task.

    • listTasks

      public void listTasks(ListTasksRequest request, io.grpc.stub.StreamObserver<ListTasksResponse> responseObserver)
       Lists tasks that match the specified filter.

    • cancelTask

      public void cancelTask(CancelTaskRequest request, io.grpc.stub.StreamObserver<Task> responseObserver)
       Cancels a task in progress.

    • subscribeToTask

      public void subscribeToTask(SubscribeToTaskRequest request, io.grpc.stub.StreamObserver<StreamResponse> responseObserver)
       Subscribes to task updates for tasks not in a terminal state.
 Returns `UnsupportedOperationError` if the task is already in a terminal state (completed, failed, canceled, rejected).

    • createTaskPushNotificationConfig

      public void createTaskPushNotificationConfig(TaskPushNotificationConfig request, io.grpc.stub.StreamObserver<TaskPushNotificationConfig> responseObserver)
       (-- api-linter: client-libraries::4232::required-fields=disabled
     api-linter: core::0133::method-signature=disabled
     api-linter: core::0133::request-message-name=disabled
     aip.dev/not-precedent: method_signature preserved for backwards compatibility --)
 Creates a push notification config for a task.

    • getTaskPushNotificationConfig

      public void getTaskPushNotificationConfig(GetTaskPushNotificationConfigRequest request, io.grpc.stub.StreamObserver<TaskPushNotificationConfig> responseObserver)
       Gets a push notification config for a task.

    • listTaskPushNotificationConfigs

      public void listTaskPushNotificationConfigs(ListTaskPushNotificationConfigsRequest request, io.grpc.stub.StreamObserver<ListTaskPushNotificationConfigsResponse> responseObserver)
       Get a list of push notifications configured for a task.

    • getExtendedAgentCard

      public void getExtendedAgentCard(GetExtendedAgentCardRequest request, io.grpc.stub.StreamObserver<AgentCard> responseObserver)
       Gets the extended agent card for the authenticated agent.

    • deleteTaskPushNotificationConfig

      public void deleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes a push notification config for a task.