Class DataA2AServiceGrpc.DataA2AServiceBlockingV2Stub (0.27.0)

0.27.0 (latest) 0.23.0 0.22.0 0.21.0 0.19.0 0.16.0 0.15.0 0.13.0 0.11.0 0.10.0 0.9.0 0.8.0 0.6.0 0.4.0 0.3.0 0.2.0 0.1.0

public static final class DataA2AServiceGrpc.DataA2AServiceBlockingV2Stub extends AbstractBlockingStub<DataA2AServiceGrpc.DataA2AServiceBlockingV2Stub>

A stub to allow clients to do synchronous 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.AbstractBlockingStub > DataA2AServiceGrpc.DataA2AServiceBlockingV2Stub

Inherited Members

io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.getCallOptions()

io.grpc.stub.AbstractStub.getChannel()

io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)

io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)

io.grpc.stub.AbstractStub.withCompression(java.lang.String)

io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)

io.grpc.stub.AbstractStub.withDeadlineAfter(java.time.Duration)

io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)

io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)

io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)

io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)

io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)

io.grpc.stub.AbstractStub.withOnReadyThreshold(int)

io.grpc.stub.AbstractStub.withWaitForReady()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

build(Channel channel, CallOptions callOptions)

protected DataA2AServiceGrpc.DataA2AServiceBlockingV2Stub build(Channel channel, CallOptions callOptions)

Parameters
Name	Description
channel	io.grpc.Channel
callOptions	io.grpc.CallOptions

Returns
Type	Description
DataA2AServiceGrpc.DataA2AServiceBlockingV2Stub

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

getAgentCard(GetAgentCardRequest request)

public AgentCard getAgentCard(GetAgentCardRequest request)

GetAgentCard returns the agent card for the agent.

Parameter
Name	Description
request	GetAgentCardRequest

Returns
Type	Description
AgentCard

Exceptions
Type	Description
io.grpc.StatusException

sendMessage(SendMessageRequest request)

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.

Parameter
Name	Description
request	SendMessageRequest

Returns
Type	Description
SendMessageResponse

Exceptions
Type	Description
io.grpc.StatusException

sendStreamingMessage(SendMessageRequest request)

public BlockingClientCall<?,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.

Parameter
Name	Description
request	SendMessageRequest

Returns
Type	Description
io.grpc.stub.BlockingClientCall<?,StreamResponse>