Class DatastoreGrpc.DatastoreStub (2.32.0) 

public static final class DatastoreGrpc.DatastoreStub extends AbstractAsyncStub<DatastoreGrpc.DatastoreStub>

A stub to allow clients to do asynchronous rpc calls to service Datastore.

Each RPC normalizes the partition IDs of the keys in its input entities, and always returns entities with keys with normalized partition IDs. This applies to all keys and entities, including those in values, except keys with both an empty path and an empty or unset partition ID. Normalization of input keys sets the project ID (if not already set) to the project ID from the request.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > DatastoreGrpc.DatastoreStub

Methods

allocateIds(AllocateIdsRequest request, StreamObserver<AllocateIdsResponse> responseObserver)

public void allocateIds(AllocateIdsRequest request, StreamObserver<AllocateIdsResponse> responseObserver)

Allocates IDs for the given keys, which is useful for referencing an entity before it is inserted.

Parameters
Name Description
request AllocateIdsRequest
responseObserver io.grpc.stub.StreamObserver<AllocateIdsResponse>

beginTransaction(BeginTransactionRequest request, StreamObserver<BeginTransactionResponse> responseObserver)

public void beginTransaction(BeginTransactionRequest request, StreamObserver<BeginTransactionResponse> responseObserver)

Begins a new transaction.

Parameters
Name Description
request BeginTransactionRequest
responseObserver io.grpc.stub.StreamObserver<BeginTransactionResponse>

build(Channel channel, CallOptions callOptions)

protected DatastoreGrpc.DatastoreStub build(Channel channel, CallOptions callOptions)
Parameters
Name Description
channel io.grpc.Channel
callOptions io.grpc.CallOptions
Returns
Type Description
DatastoreGrpc.DatastoreStub
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

commit(CommitRequest request, StreamObserver<CommitResponse> responseObserver)

public void commit(CommitRequest request, StreamObserver<CommitResponse> responseObserver)

Commits a transaction, optionally creating, deleting or modifying some entities.

Parameters
Name Description
request CommitRequest
responseObserver io.grpc.stub.StreamObserver<CommitResponse>

lookup(LookupRequest request, StreamObserver<LookupResponse> responseObserver)

public void lookup(LookupRequest request, StreamObserver<LookupResponse> responseObserver)

Looks up entities by key.

Parameters
Name Description
request LookupRequest
responseObserver io.grpc.stub.StreamObserver<LookupResponse>

reserveIds(ReserveIdsRequest request, StreamObserver<ReserveIdsResponse> responseObserver)

public void reserveIds(ReserveIdsRequest request, StreamObserver<ReserveIdsResponse> responseObserver)

Prevents the supplied keys' IDs from being auto-allocated by Cloud Datastore.

Parameters
Name Description
request ReserveIdsRequest
responseObserver io.grpc.stub.StreamObserver<ReserveIdsResponse>

rollback(RollbackRequest request, StreamObserver<RollbackResponse> responseObserver)

public void rollback(RollbackRequest request, StreamObserver<RollbackResponse> responseObserver)

Rolls back a transaction.

Parameters
Name Description
request RollbackRequest
responseObserver io.grpc.stub.StreamObserver<RollbackResponse>

runAggregationQuery(RunAggregationQueryRequest request, StreamObserver<RunAggregationQueryResponse> responseObserver)

public void runAggregationQuery(RunAggregationQueryRequest request, StreamObserver<RunAggregationQueryResponse> responseObserver)

Runs an aggregation query.

Parameters
Name Description
request RunAggregationQueryRequest
responseObserver io.grpc.stub.StreamObserver<RunAggregationQueryResponse>

runQuery(RunQueryRequest request, StreamObserver<RunQueryResponse> responseObserver)

public void runQuery(RunQueryRequest request, StreamObserver<RunQueryResponse> responseObserver)

Queries for entities.

Parameters
Name Description
request RunQueryRequest
responseObserver io.grpc.stub.StreamObserver<RunQueryResponse>