Package com.google.spanner.adapter.v1
Class AdapterGrpc.AdapterStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<AdapterGrpc.AdapterStub>
com.google.spanner.adapter.v1.AdapterGrpc.AdapterStub
- Enclosing class:
- AdapterGrpc
public static final class AdapterGrpc.AdapterStub
extends io.grpc.stub.AbstractAsyncStub<AdapterGrpc.AdapterStub>
A stub to allow clients to do asynchronous 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.
-
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 TypeMethodDescriptionvoidadaptMessage(AdaptMessageRequest request, io.grpc.stub.StreamObserver<AdaptMessageResponse> responseObserver) Handles a single message from the client and returns the result as a stream.protected AdapterGrpc.AdapterStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) voidcreateSession(CreateSessionRequest request, io.grpc.stub.StreamObserver<Session> responseObserver) Creates a new session to be used for requests made by the adapter.Methods inherited from class io.grpc.stub.AbstractAsyncStub
newStub, newStubMethods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
- Specified by:
buildin classio.grpc.stub.AbstractStub<AdapterGrpc.AdapterStub>
-
createSession
public void createSession(CreateSessionRequest request, io.grpc.stub.StreamObserver<Session> responseObserver) 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.
-
adaptMessage
public void adaptMessage(AdaptMessageRequest request, io.grpc.stub.StreamObserver<AdaptMessageResponse> responseObserver) 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.
-