Package org.a2aproject.sdk.compat03.grpc

Class A2AServiceGrpc.A2AServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<A2AServiceGrpc.A2AServiceBlockingStub>

org.a2aproject.sdk.compat03.grpc.A2AServiceGrpc.A2AServiceBlockingStub

Enclosing class:

A2AServiceGrpc

public static final class A2AServiceGrpc.A2AServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<A2AServiceGrpc.A2AServiceBlockingStub>

A stub to allow clients to do limited synchronous rpc calls to service A2AService.

 A2AService defines the gRPC version of the A2A protocol. This has a slightly
 different shape than the JSONRPC version to better conform to AIP-127,
 where appropriate. The nouns are AgentCard, Message, Task and
 TaskPushNotificationConfig.
 - Messages are not a standard resource so there is no get/delete/update/list
   interface, only a send and stream custom methods.
 - Tasks have a get interface and custom cancel and subscribe methods.
 - TaskPushNotificationConfig are a resource whose parent is a task.
   They have get, list and create methods.
 - AgentCard is a static resource with only a get method.
 fields are not present as they don't comply with AIP rules, and the
 optional history_length on the get task method is not present as it also
 violates AIP-127 and AIP-131.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected A2AServiceGrpc.A2AServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
Task	cancelTask(CancelTaskRequest request)	Cancel a task from the agent.
TaskPushNotificationConfig	createTaskPushNotificationConfig(CreateTaskPushNotificationConfigRequest request)	Set a push notification config for a task.
com.google.protobuf.Empty	deleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigRequest request)	Delete a push notification config for a task.
AgentCard	getAgentCard(GetAgentCardRequest request)	GetAgentCard returns the agent card for the agent.
Task	getTask(GetTaskRequest request)	Get the current state of a task from the agent.
TaskPushNotificationConfig	getTaskPushNotificationConfig(GetTaskPushNotificationConfigRequest request)	Get a push notification config for a task.
ListTaskPushNotificationConfigResponse	listTaskPushNotificationConfig(ListTaskPushNotificationConfigRequest request)	Get a list of push notifications configured for a task.
SendMessageResponse	sendMessage(SendMessageRequest request)	Send a message to the agent.
Iterator<StreamResponse>	sendStreamingMessage(SendMessageRequest request)	SendStreamingMessage is a streaming call that will return a stream of task update events until the Task is in an interrupted or terminal state.
Iterator<StreamResponse>	taskSubscription(TaskSubscriptionRequest request)	TaskSubscription is a streaming call that will return a stream of task update events.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Details

build

protected A2AServiceGrpc.A2AServiceBlockingStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<A2AServiceGrpc.A2AServiceBlockingStub>

sendMessage

public SendMessageResponse sendMessage(SendMessageRequest request)

 Send a message to the agent. This is a blocking call that will return the
 task once it is completed, or a LRO if requested.
 

sendStreamingMessage

public Iterator<StreamResponse> sendStreamingMessage(SendMessageRequest request)

 SendStreamingMessage is a streaming call that will return a stream of
 task update events until the Task is in an interrupted or terminal state.
 

getTask

public Task getTask(GetTaskRequest request)

 Get the current state of a task from the agent.
 

cancelTask

public Task cancelTask(CancelTaskRequest request)

 Cancel a task from the agent. If supported one should expect no
 more task updates for the task.
 

taskSubscription

public Iterator<StreamResponse> taskSubscription(TaskSubscriptionRequest request)

 TaskSubscription is a streaming call that will return a stream of task
 update events. This attaches the stream to an existing in process task.
 If the task is complete the stream will return the completed task (like
 GetTask) and close the stream.
 

createTaskPushNotificationConfig

public TaskPushNotificationConfig createTaskPushNotificationConfig(CreateTaskPushNotificationConfigRequest request)

 Set a push notification config for a task.
 

getTaskPushNotificationConfig

public TaskPushNotificationConfig getTaskPushNotificationConfig(GetTaskPushNotificationConfigRequest request)

 Get a push notification config for a task.
 

listTaskPushNotificationConfig

public ListTaskPushNotificationConfigResponse listTaskPushNotificationConfig(ListTaskPushNotificationConfigRequest request)

 Get a list of push notifications configured for a task.
 

getAgentCard

public AgentCard getAgentCard(GetAgentCardRequest request)

 GetAgentCard returns the agent card for the agent.
 

deleteTaskPushNotificationConfig

public com.google.protobuf.Empty deleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigRequest request)

 Delete a push notification config for a task.