com.google.cloud.datastore

Class RetryAndTraceDatastoreRpcDecorator

java.lang.Object

com.google.cloud.datastore.RetryAndTraceDatastoreRpcDecorator

All Implemented Interfaces:

DatastoreRpc, com.google.cloud.ServiceRpc

@InternalApi
public class RetryAndTraceDatastoreRpcDecorator
extends Object
implements DatastoreRpc

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

Constructor Summary

Constructors

Constructor and Description
RetryAndTraceDatastoreRpcDecorator(DatastoreRpc datastoreRpc, TraceUtil traceUtil, com.google.api.gax.retrying.RetrySettings retrySettings, DatastoreOptions datastoreOptions)

Method Summary

Modifier and Type	Method and Description
AllocateIdsResponse	allocateIds(AllocateIdsRequest request) Sends an allocate IDs request.
BeginTransactionResponse	beginTransaction(BeginTransactionRequest request) Sends a begin transaction request.
CommitResponse	commit(CommitRequest request) Sends a commit request.
<O> O	invokeRpc(Callable<O> block, String startSpan)
LookupResponse	lookup(LookupRequest request) Sends a lookup request.
ReserveIdsResponse	reserveIds(ReserveIdsRequest request) Sends a reserveIds request.
RollbackResponse	rollback(RollbackRequest request) Sends a rollback request.
RunAggregationQueryResponse	runAggregationQuery(RunAggregationQueryRequest request) Sends a request to run an aggregation query.
RunQueryResponse	runQuery(RunQueryRequest request) Sends a request to run a query.

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryAndTraceDatastoreRpcDecorator

public RetryAndTraceDatastoreRpcDecorator(DatastoreRpc datastoreRpc,
                                          TraceUtil traceUtil,
                                          com.google.api.gax.retrying.RetrySettings retrySettings,
                                          DatastoreOptions datastoreOptions)

Method Detail

allocateIds

public AllocateIdsResponse allocateIds(AllocateIdsRequest request)

Description copied from interface: DatastoreRpc

Sends an allocate IDs request.

Specified by:

allocateIds in interface DatastoreRpc

beginTransaction

public BeginTransactionResponse beginTransaction(BeginTransactionRequest request)
                                          throws DatastoreException

Description copied from interface: DatastoreRpc

Sends a begin transaction request.

Specified by:

beginTransaction in interface DatastoreRpc

Throws:

DatastoreException - upon failure

commit

public CommitResponse commit(CommitRequest request)

Description copied from interface: DatastoreRpc

Sends a commit request.

Specified by:

commit in interface DatastoreRpc

lookup

public LookupResponse lookup(LookupRequest request)

Description copied from interface: DatastoreRpc

Sends a lookup request.

Specified by:

lookup in interface DatastoreRpc

reserveIds

public ReserveIdsResponse reserveIds(ReserveIdsRequest request)

Description copied from interface: DatastoreRpc

Sends a reserveIds request.

Specified by:

reserveIds in interface DatastoreRpc

rollback

public RollbackResponse rollback(RollbackRequest request)

Description copied from interface: DatastoreRpc

Sends a rollback request.

Specified by:

rollback in interface DatastoreRpc

runQuery

public RunQueryResponse runQuery(RunQueryRequest request)

Description copied from interface: DatastoreRpc

Sends a request to run a query.

Specified by:

runQuery in interface DatastoreRpc

runAggregationQuery

public RunAggregationQueryResponse runAggregationQuery(RunAggregationQueryRequest request)

Description copied from interface: DatastoreRpc

Sends a request to run an aggregation query.

Specified by:

runAggregationQuery in interface DatastoreRpc

invokeRpc

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