Class A2AServiceGrpc.A2AServiceBlockingV2Stub

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

  • Method Details

    • build

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

    • sendMessage

      public SendMessageResponse sendMessage(SendMessageRequest request) throws io.grpc.StatusException
      Sends a message to an agent.
      Throws:
      io.grpc.StatusException

    • sendStreamingMessage

      @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?, StreamResponse> sendStreamingMessage(SendMessageRequest request)
      Sends a streaming message to an agent, allowing for real-time interaction and status updates.
Streaming version of `SendMessage`

    • getTask

      public Task getTask(GetTaskRequest request) throws io.grpc.StatusException
      Gets the latest state of a task.
      Throws:
      io.grpc.StatusException

    • listTasks

      public ListTasksResponse listTasks(ListTasksRequest request) throws io.grpc.StatusException
      Lists tasks that match the specified filter.
      Throws:
      io.grpc.StatusException

    • cancelTask

      public Task cancelTask(CancelTaskRequest request) throws io.grpc.StatusException
      Cancels a task in progress.
      Throws:
      io.grpc.StatusException

    • subscribeToTask

      @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?, StreamResponse> subscribeToTask(SubscribeToTaskRequest request)
      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 TaskPushNotificationConfig createTaskPushNotificationConfig(TaskPushNotificationConfig request) throws io.grpc.StatusException
      (-- 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.
      Throws:
      io.grpc.StatusException

    • getTaskPushNotificationConfig

      public TaskPushNotificationConfig getTaskPushNotificationConfig(GetTaskPushNotificationConfigRequest request) throws io.grpc.StatusException
      Gets a push notification config for a task.
      Throws:
      io.grpc.StatusException

    • listTaskPushNotificationConfigs

      public ListTaskPushNotificationConfigsResponse listTaskPushNotificationConfigs(ListTaskPushNotificationConfigsRequest request) throws io.grpc.StatusException
      Get a list of push notifications configured for a task.
      Throws:
      io.grpc.StatusException

    • getExtendedAgentCard

      public AgentCard getExtendedAgentCard(GetExtendedAgentCardRequest request) throws io.grpc.StatusException
      Gets the extended agent card for the authenticated agent.
      Throws:
      io.grpc.StatusException

    • deleteTaskPushNotificationConfig

      public com.google.protobuf.Empty deleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigRequest request) throws io.grpc.StatusException
      Deletes a push notification config for a task.
      Throws:
      io.grpc.StatusException