Interface DatastoreGrpc.AsyncService (2.28.1) 

public static interface DatastoreGrpc.AsyncService

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.

Methods

allocateIds(AllocateIdsRequest request, StreamObserver<AllocateIdsResponse> responseObserver)

public default 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 default void beginTransaction(BeginTransactionRequest request, StreamObserver<BeginTransactionResponse> responseObserver)

Begins a new transaction.

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

commit(CommitRequest request, StreamObserver<CommitResponse> responseObserver)

public default 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 default 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 default 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 default 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 default 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 default void runQuery(RunQueryRequest request, StreamObserver<RunQueryResponse> responseObserver)

Queries for entities.

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