Class RetryAndTraceDatastoreRpcDecorator (2.23.0)

public class RetryAndTraceDatastoreRpcDecorator implements DatastoreRpc

An implementation of DatastoreRpc which acts as a Decorator and decorates the underlying DatastoreRpc with the logic of retry and Traceability.

Inheritance

java.lang.Object > RetryAndTraceDatastoreRpcDecorator

Implements

DatastoreRpc

Constructors

RetryAndTraceDatastoreRpcDecorator(DatastoreRpc datastoreRpc, TraceUtil otelTraceUtil, RetrySettings retrySettings, DatastoreOptions datastoreOptions)

public RetryAndTraceDatastoreRpcDecorator(DatastoreRpc datastoreRpc, TraceUtil otelTraceUtil, RetrySettings retrySettings, DatastoreOptions datastoreOptions)
Parameters
Name Description
datastoreRpc DatastoreRpc
otelTraceUtil TraceUtil
retrySettings RetrySettings
datastoreOptions DatastoreOptions

Methods

<O>invokeRpc(Callable<O> block, String startSpan)

public O <O>invokeRpc(Callable<O> block, String startSpan)
Parameters
Name Description
block Callable<O>
startSpan String
Returns
Type Description
O

allocateIds(AllocateIdsRequest request)

public AllocateIdsResponse allocateIds(AllocateIdsRequest request)

Sends an allocate IDs request.

Parameter
Name Description
request AllocateIdsRequest
Returns
Type Description
AllocateIdsResponse

beginTransaction(BeginTransactionRequest request)

public BeginTransactionResponse beginTransaction(BeginTransactionRequest request)

Sends a begin transaction request.

Parameter
Name Description
request BeginTransactionRequest
Returns
Type Description
BeginTransactionResponse
Exceptions
Type Description
DatastoreException

commit(CommitRequest request)

public CommitResponse commit(CommitRequest request)

Sends a commit request.

Parameter
Name Description
request CommitRequest
Returns
Type Description
CommitResponse

lookup(LookupRequest request)

public LookupResponse lookup(LookupRequest request)

Sends a lookup request.

Parameter
Name Description
request LookupRequest
Returns
Type Description
LookupResponse

reserveIds(ReserveIdsRequest request)

public ReserveIdsResponse reserveIds(ReserveIdsRequest request)

Sends a reserveIds request.

Parameter
Name Description
request ReserveIdsRequest
Returns
Type Description
ReserveIdsResponse

rollback(RollbackRequest request)

public RollbackResponse rollback(RollbackRequest request)

Sends a rollback request.

Parameter
Name Description
request RollbackRequest
Returns
Type Description
RollbackResponse

runAggregationQuery(RunAggregationQueryRequest request)

public RunAggregationQueryResponse runAggregationQuery(RunAggregationQueryRequest request)

Sends a request to run an aggregation query.

Parameter
Name Description
request RunAggregationQueryRequest
Returns
Type Description
RunAggregationQueryResponse

runQuery(RunQueryRequest request)

public RunQueryResponse runQuery(RunQueryRequest request)

Sends a request to run a query.

Parameter
Name Description
request RunQueryRequest
Returns
Type Description
RunQueryResponse