Package org.a2aproject.sdk.grpc

Class A2AServiceGrpc.A2AServiceBlockingV2Stub

java.lang.Object
io.grpc.stub.AbstractStub<S>
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