public class CloudExecutorImpl extends SpannerExecutorProxyGrpc.SpannerExecutorProxyImplBase
Send proxied action requests through Spanner Cloud API.
Inheritance
java.lang.Object > com.google.spanner.executor.v1.SpannerExecutorProxyGrpc.SpannerExecutorProxyImplBase > CloudExecutorImplInherited Members
com.google.spanner.executor.v1.SpannerExecutorProxyGrpc.SpannerExecutorProxyImplBase.bindService()
com.google.spanner.executor.v1.SpannerExecutorProxyGrpc.SpannerExecutorProxyImplBase.executeActionAsync(io.grpc.stub.StreamObserver<com.google.spanner.executor.v1.SpannerAsyncActionResponse>)
Constructors
CloudExecutorImpl(boolean enableGrpcFaultInjector)
public CloudExecutorImpl(boolean enableGrpcFaultInjector)
Parameter | |
---|---|
Name | Description |
enableGrpcFaultInjector | boolean |
Methods
executeActionAsync(StreamObserver<SpannerAsyncActionResponse> responseObserver)
public StreamObserver<SpannerAsyncActionRequest> executeActionAsync(StreamObserver<SpannerAsyncActionResponse> responseObserver)
Execute SpannerAsync action requests.
Parameter | |
---|---|
Name | Description |
responseObserver | io.grpc.stub.StreamObserver<com.google.spanner.executor.v1.SpannerAsyncActionResponse> |
Returns | |
---|---|
Type | Description |
io.grpc.stub.StreamObserver<com.google.spanner.executor.v1.SpannerAsyncActionRequest> |
com.google.spanner.executor.v1.SpannerExecutorProxyGrpc.SpannerExecutorProxyImplBase.executeActionAsync(io.grpc.stub.StreamObserver<com.google.spanner.executor.v1.SpannerAsyncActionResponse>)