Class CloudExecutorImpl (6.95.1) 

public class CloudExecutorImpl extends SpannerExecutorProxyGrpc.SpannerExecutorProxyImplBase

Send proxied action requests through Spanner Cloud API.

Inheritance

java.lang.Object > SpannerExecutorProxyGrpc.SpannerExecutorProxyImplBase > CloudExecutorImpl

Constructors

CloudExecutorImpl(boolean enableGrpcFaultInjector, double multiplexedSessionOperationsRatio)

public CloudExecutorImpl(boolean enableGrpcFaultInjector, double multiplexedSessionOperationsRatio)
Parameters
Name Description
enableGrpcFaultInjector boolean
multiplexedSessionOperationsRatio double

Methods

executeActionAsync(StreamObserver responseObserver)

public StreamObserver executeActionAsync(StreamObserver responseObserver)

Execute SpannerAsync action requests.

Parameter
Name Description
responseObserver io.grpc.stub.StreamObserver<SpannerAsyncActionResponse>
Returns
Type Description
io.grpc.stub.StreamObserver<SpannerAsyncActionRequest>