com.google.cloud.bigtable.data.v2.stub.metrics

Class MeasuredUnaryCallable<RequestT,ResponseT>

java.lang.Object

com.google.api.gax.rpc.UnaryCallable<RequestT,ResponseT>

com.google.cloud.bigtable.data.v2.stub.metrics.MeasuredUnaryCallable<RequestT,ResponseT>

@InternalApi
public class MeasuredUnaryCallable<RequestT,ResponseT>
extends com.google.api.gax.rpc.UnaryCallable<RequestT,ResponseT>

This callable will instrument callable invocations using OpenCensus stats.

Recorded stats:

RpcMeasureConstants.BIGTABLE_OP_LATENCY

the total time it took the operation across all of its retry attempts to complete

For internal use only.

Constructor Summary

Constructors

Constructor and Description
MeasuredUnaryCallable(com.google.api.gax.rpc.UnaryCallable<RequestT,ResponseT> innerCallable, String methodName, io.opencensus.tags.Tagger tagger, io.opencensus.stats.StatsRecorder stats, com.google.api.core.ApiClock clock)

Method Summary

Modifier and Type	Method and Description
com.google.api.core.ApiFuture<ResponseT>	futureCall(RequestT request, com.google.api.gax.rpc.ApiCallContext context)

Methods inherited from class com.google.api.gax.rpc.UnaryCallable

call, call, futureCall, withDefaultCallContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MeasuredUnaryCallable

public MeasuredUnaryCallable(@Nonnull
                             com.google.api.gax.rpc.UnaryCallable<RequestT,ResponseT> innerCallable,
                             @Nonnull
                             String methodName,
                             @Nonnull
                             io.opencensus.tags.Tagger tagger,
                             @Nonnull
                             io.opencensus.stats.StatsRecorder stats,
                             @Nonnull
                             com.google.api.core.ApiClock clock)

Method Detail

futureCall

public com.google.api.core.ApiFuture<ResponseT> futureCall(RequestT request,
                                                           com.google.api.gax.rpc.ApiCallContext context)

Specified by:

futureCall in class com.google.api.gax.rpc.UnaryCallable<RequestT,ResponseT>