Class AdapterGrpc.AdapterBlockingStub (0.30.0)

0.30.0 (latest) 0.29.0 0.27.0 0.24.0 0.23.0 0.21.0 0.19.0 0.18.0 0.16.0 0.14.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.6.0 0.4.0 0.3.0

public static final class AdapterGrpc.AdapterBlockingStub extends AbstractBlockingStub<AdapterGrpc.AdapterBlockingStub>

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

Cloud Spanner Adapter API The Cloud Spanner Adapter service allows native drivers of supported database dialects to interact directly with Cloud Spanner by wrapping the underlying wire protocol used by the driver in a gRPC stream.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractBlockingStub > AdapterGrpc.AdapterBlockingStub

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

adaptMessage(AdaptMessageRequest request)

public Iterator<AdaptMessageResponse> adaptMessage(AdaptMessageRequest request)

Handles a single message from the client and returns the result as a stream. The server will interpret the message frame and respond with message frames to the client.

Parameter
Name	Description
request	AdaptMessageRequest

Returns
Type	Description
Iterator<AdaptMessageResponse>

build(Channel channel, CallOptions callOptions)

protected AdapterGrpc.AdapterBlockingStub build(Channel channel, CallOptions callOptions)

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

Returns
Type	Description
AdapterGrpc.AdapterBlockingStub

Overrides

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

createSession(CreateSessionRequest request)

public Session createSession(CreateSessionRequest request)

Creates a new session to be used for requests made by the adapter. A session identifies a specific incarnation of a database resource and is meant to be reused across many AdaptMessage calls.

Parameter
Name	Description
request	CreateSessionRequest

Returns
Type	Description
Session