Package org.a2aproject.sdk.grpc

Class A2AServiceGrpc.A2AServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

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

org.a2aproject.sdk.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.

 Provides operations for interacting with agents using the A2A protocol.
 

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)	Cancels a task in progress.
TaskPushNotificationConfig	createTaskPushNotificationConfig(TaskPushNotificationConfig request)	(-- 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.
com.google.protobuf.Empty	deleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigRequest request)	Deletes a push notification config for a task.
AgentCard	getExtendedAgentCard(GetExtendedAgentCardRequest request)	Gets the extended agent card for the authenticated agent.
Task	getTask(GetTaskRequest request)	Gets the latest state of a task.
TaskPushNotificationConfig	getTaskPushNotificationConfig(GetTaskPushNotificationConfigRequest request)	Gets a push notification config for a task.
ListTaskPushNotificationConfigsResponse	listTaskPushNotificationConfigs(ListTaskPushNotificationConfigsRequest request)	Get a list of push notifications configured for a task.
ListTasksResponse	listTasks(ListTasksRequest request)	Lists tasks that match the specified filter.
SendMessageResponse	sendMessage(SendMessageRequest request)	Sends a message to an agent.
Iterator<StreamResponse>	sendStreamingMessage(SendMessageRequest request)	Sends a streaming message to an agent, allowing for real-time interaction and status updates.
Iterator<StreamResponse>	subscribeToTask(SubscribeToTaskRequest request)	Subscribes to task updates for tasks not in a terminal state.

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)

 Sends a message to an agent.
 

sendStreamingMessage

public Iterator<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)

 Gets the latest state of a task.
 

listTasks

public ListTasksResponse listTasks(ListTasksRequest request)

 Lists tasks that match the specified filter.
 

cancelTask

public Task cancelTask(CancelTaskRequest request)

 Cancels a task in progress.
 

subscribeToTask

public Iterator<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)

 (-- 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 TaskPushNotificationConfig getTaskPushNotificationConfig(GetTaskPushNotificationConfigRequest request)

 Gets a push notification config for a task.
 

listTaskPushNotificationConfigs

public ListTaskPushNotificationConfigsResponse listTaskPushNotificationConfigs(ListTaskPushNotificationConfigsRequest request)

 Get a list of push notifications configured for a task.
 

getExtendedAgentCard

public AgentCard getExtendedAgentCard(GetExtendedAgentCardRequest request)

 Gets the extended agent card for the authenticated agent.
 

deleteTaskPushNotificationConfig

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

 Deletes a push notification config for a task.