Class DataA2AServiceGrpc.DataA2AServiceStub (0.27.0) 

public static final class DataA2AServiceGrpc.DataA2AServiceStub extends AbstractAsyncStub<DataA2AServiceGrpc.DataA2AServiceStub>

A stub to allow clients to do asynchronous rpc calls to service DataA2AService.

DataA2AService defines the Agent-to-Agent (A2A) protocol service for Gemini Data Analytics.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > DataA2AServiceGrpc.DataA2AServiceStub

Methods

build(Channel channel, CallOptions callOptions)

protected DataA2AServiceGrpc.DataA2AServiceStub build(Channel channel, CallOptions callOptions)
Parameters
Name Description
channel io.grpc.Channel
callOptions io.grpc.CallOptions
Returns
Type Description
DataA2AServiceGrpc.DataA2AServiceStub
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

getAgentCard(GetAgentCardRequest request, StreamObserver<AgentCard> responseObserver)

public void getAgentCard(GetAgentCardRequest request, StreamObserver<AgentCard> responseObserver)

GetAgentCard returns the agent card for the agent.

Parameters
Name Description
request GetAgentCardRequest
responseObserver io.grpc.stub.StreamObserver<AgentCard>

sendMessage(SendMessageRequest request, StreamObserver<SendMessageResponse> responseObserver)

public void sendMessage(SendMessageRequest request, StreamObserver<SendMessageResponse> responseObserver)

Send a message to the agent. This is a blocking call that will return the task once it is completed.

Parameters
Name Description
request SendMessageRequest
responseObserver io.grpc.stub.StreamObserver<SendMessageResponse>

sendStreamingMessage(SendMessageRequest request, StreamObserver<StreamResponse> responseObserver)

public void sendStreamingMessage(SendMessageRequest request, StreamObserver<StreamResponse> responseObserver)

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

Parameters
Name Description
request SendMessageRequest
responseObserver io.grpc.stub.StreamObserver<StreamResponse>