com.google.cloud.bigtable.grpc.async
Interface BigtableAsyncRpc<REQUEST,RESPONSE>
-
public interface BigtableAsyncRpc<REQUEST,RESPONSE>
This interface represents a logical asynchronous RPC end point, including creating aClientCall
for a new request.- Version:
- $Id: $Id
- Author:
- sduskis
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface and Description static class
BigtableAsyncRpc.RpcMetrics
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description io.grpc.MethodDescriptor<REQUEST,RESPONSE>
getMethodDescriptor()
getMethodDescriptor.BigtableAsyncRpc.RpcMetrics
getRpcMetrics()
boolean
isRetryable(REQUEST request)
Can this request be retried?io.grpc.ClientCall<REQUEST,RESPONSE>
newCall(io.grpc.CallOptions callOptions)
Creates aClientCall
it.void
start(REQUEST request, io.grpc.ClientCall.Listener<RESPONSE> listener, io.grpc.Metadata metadata, io.grpc.ClientCall<REQUEST,RESPONSE> call)
Starts aClientCall
.
-
-
-
Method Detail
-
newCall
io.grpc.ClientCall<REQUEST,RESPONSE> newCall(io.grpc.CallOptions callOptions)
Creates aClientCall
it.- Parameters:
callOptions
- A set of gRPC options to use on this call.- Returns:
- A ClientCall that represents a new request.
-
start
void start(REQUEST request, io.grpc.ClientCall.Listener<RESPONSE> listener, io.grpc.Metadata metadata, io.grpc.ClientCall<REQUEST,RESPONSE> call)
Starts aClientCall
.- Parameters:
request
- The request to send.listener
- A listener which handles responses.metadata
- A set of predefined headers to use.call
- AClientCall
.
-
isRetryable
boolean isRetryable(REQUEST request)
Can this request be retried?- Parameters:
request
- The request to send which may require introspection to determine retryability.- Returns:
- true if the request can be retried.
-
getMethodDescriptor
io.grpc.MethodDescriptor<REQUEST,RESPONSE> getMethodDescriptor()
getMethodDescriptor.- Returns:
MethodDescriptor
that describes the logical endpoint.
-
getRpcMetrics
BigtableAsyncRpc.RpcMetrics getRpcMetrics()
-
-