Class DatastoreGrpc.DatastoreFutureStub (2.28.1)
Stay organized with collections Save and categorize content based on your preferences.

public static final class DatastoreGrpc.DatastoreFutureStub extends AbstractFutureStub<DatastoreGrpc.DatastoreFutureStub>

A stub to allow clients to do ListenableFuture-style 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.AbstractFutureStub > DatastoreGrpc.DatastoreFutureStub

Inherited Members

io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.getCallOptions()

io.grpc.stub.AbstractStub.getChannel()

io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)

io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)

io.grpc.stub.AbstractStub.withCompression(java.lang.String)

io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)

io.grpc.stub.AbstractStub.withDeadlineAfter(java.time.Duration)

io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)

io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)

io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)

io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)

io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)

io.grpc.stub.AbstractStub.withOnReadyThreshold(int)

io.grpc.stub.AbstractStub.withWaitForReady()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

allocateIds(AllocateIdsRequest request)

public ListenableFuture<AllocateIdsResponse> allocateIds(AllocateIdsRequest request)

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

Parameter
Name	Description
`request`	`AllocateIdsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<AllocateIdsResponse>`

beginTransaction(BeginTransactionRequest request)

public ListenableFuture<BeginTransactionResponse> beginTransaction(BeginTransactionRequest request)

Begins a new transaction.

Parameter
Name	Description
`request`	`BeginTransactionRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<BeginTransactionResponse>`

build(Channel channel, CallOptions callOptions)

protected DatastoreGrpc.DatastoreFutureStub build(Channel channel, CallOptions callOptions)

Parameters
Name	Description
`channel`	`io.grpc.Channel`
`callOptions`	`io.grpc.CallOptions`

Returns
Type	Description
`DatastoreGrpc.DatastoreFutureStub`

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

commit(CommitRequest request)

public ListenableFuture<CommitResponse> commit(CommitRequest request)

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

Parameter
Name	Description
`request`	`CommitRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<CommitResponse>`

lookup(LookupRequest request)

public ListenableFuture<LookupResponse> lookup(LookupRequest request)

Looks up entities by key.

Parameter
Name	Description
`request`	`LookupRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<LookupResponse>`

reserveIds(ReserveIdsRequest request)

public ListenableFuture<ReserveIdsResponse> reserveIds(ReserveIdsRequest request)

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

Parameter
Name	Description
`request`	`ReserveIdsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<ReserveIdsResponse>`

rollback(RollbackRequest request)

public ListenableFuture<RollbackResponse> rollback(RollbackRequest request)

Rolls back a transaction.

Parameter
Name	Description
`request`	`RollbackRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<RollbackResponse>`

runAggregationQuery(RunAggregationQueryRequest request)

public ListenableFuture<RunAggregationQueryResponse> runAggregationQuery(RunAggregationQueryRequest request)

Runs an aggregation query.

Parameter
Name	Description
`request`	`RunAggregationQueryRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<RunAggregationQueryResponse>`

runQuery(RunQueryRequest request)

public ListenableFuture<RunQueryResponse> runQuery(RunQueryRequest request)

Queries for entities.

Parameter
Name	Description
`request`	`RunQueryRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<RunQueryResponse>`

Class DatastoreGrpc.DatastoreFutureStub (2.28.1) Stay organized with collections Save and categorize content based on your preferences.