Class AdapterGrpc.AdapterBlockingV2Stub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractBlockingStub<AdapterGrpc.AdapterBlockingV2Stub>
com.google.spanner.adapter.v1.AdapterGrpc.AdapterBlockingV2Stub
Enclosing class:
AdapterGrpc

public static final class AdapterGrpc.AdapterBlockingV2Stub extends io.grpc.stub.AbstractBlockingStub<AdapterGrpc.AdapterBlockingV2Stub>
A stub to allow clients to do 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.
 
  • 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
    io.grpc.stub.BlockingClientCall<?,AdaptMessageResponse>
    Handles a single message from the client and returns the result as a stream.
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    Creates a new session to be used for requests made by the adapter.

    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 AdapterGrpc.AdapterBlockingV2Stub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<AdapterGrpc.AdapterBlockingV2Stub>
    • createSession

      public Session createSession(CreateSessionRequest request) throws io.grpc.StatusException
       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.
       
      Throws:
      io.grpc.StatusException
    • adaptMessage

      @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?,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.