public class AwaitConsistencyCallableV2 extends UnaryCallable<ConsistencyRequest,Void>Decoupled modern consistency polling callable for V2 client.
This callable waits until either replication or Data Boost has caught up to the point it was called. It wraps GenerateConsistencyToken and CheckConsistency RPCs.
Static Methods
create(UnaryCallable<GenerateConsistencyTokenRequest,GenerateConsistencyTokenResponse> generateCallable, UnaryCallable<CheckConsistencyRequest,CheckConsistencyResponse> checkCallable, ApiClock clock, ScheduledExecutorService executor, RetrySettings pollingSettings)
public static AwaitConsistencyCallableV2 create(UnaryCallable<GenerateConsistencyTokenRequest,GenerateConsistencyTokenResponse> generateCallable, UnaryCallable<CheckConsistencyRequest,CheckConsistencyResponse> checkCallable, ApiClock clock, ScheduledExecutorService executor, RetrySettings pollingSettings)| Parameters | |
|---|---|
| Name | Description |
generateCallable |
UnaryCallable<com.google.bigtable.admin.v2.GenerateConsistencyTokenRequest,com.google.bigtable.admin.v2.GenerateConsistencyTokenResponse> |
checkCallable |
UnaryCallable<com.google.bigtable.admin.v2.CheckConsistencyRequest,com.google.bigtable.admin.v2.CheckConsistencyResponse> |
clock |
ApiClock |
executor |
ScheduledExecutorService |
pollingSettings |
RetrySettings |
| Returns | |
|---|---|
| Type | Description |
AwaitConsistencyCallableV2 |
|
Methods
futureCall(ConsistencyRequest consistencyRequest, ApiCallContext apiCallContext)
public ApiFuture<Void> futureCall(ConsistencyRequest consistencyRequest, ApiCallContext apiCallContext)| Parameters | |
|---|---|
| Name | Description |
consistencyRequest |
ConsistencyRequest |
apiCallContext |
ApiCallContext |
| Returns | |
|---|---|
| Type | Description |
ApiFuture<Void> |
|
com.google.api.gax.rpc.UnaryCallable.futureCall(RequestT,com.google.api.gax.rpc.ApiCallContext)