public class GrpcFirestoreRpc implements FirestoreRpc
GRPC client implementation of the Firestore RPC methods. Exposes FirestoreOptions on top of the GRPC-based Firestore GAPIC client.
Implements
FirestoreRpcConstructors
GrpcFirestoreRpc(FirestoreOptions options)
public GrpcFirestoreRpc(FirestoreOptions options)
Name | Description |
options | FirestoreOptions |
Methods
batchGetDocumentsCallable()
public ServerStreamingCallable<BatchGetDocumentsRequest,BatchGetDocumentsResponse> batchGetDocumentsCallable()
Gets multiple documents.
Type | Description |
ServerStreamingCallable<BatchGetDocumentsRequest,BatchGetDocumentsResponse> |
batchWriteCallable()
public UnaryCallable<BatchWriteRequest,BatchWriteResponse> batchWriteCallable()
Type | Description |
UnaryCallable<BatchWriteRequest,BatchWriteResponse> |
beginTransactionCallable()
public UnaryCallable<BeginTransactionRequest,BeginTransactionResponse> beginTransactionCallable()
Starts a new transaction.
Type | Description |
UnaryCallable<BeginTransactionRequest,BeginTransactionResponse> |
close()
public void close()
Type | Description |
Exception |
commitCallable()
public UnaryCallable<CommitRequest,CommitResponse> commitCallable()
Commits a transaction, while optionally updating documents.
Type | Description |
UnaryCallable<CommitRequest,CommitResponse> |
getExecutor()
public ScheduledExecutorService getExecutor()
Returns the executor used by the GAPIC client.
Type | Description |
ScheduledExecutorService |
listCollectionIdsPagedCallable()
public UnaryCallable<ListCollectionIdsRequest,FirestoreClient.ListCollectionIdsPagedResponse> listCollectionIdsPagedCallable()
Returns a list of collections IDs.
Type | Description |
UnaryCallable<ListCollectionIdsRequest,ListCollectionIdsPagedResponse> |
listDocumentsPagedCallable()
public UnaryCallable<ListDocumentsRequest,FirestoreClient.ListDocumentsPagedResponse> listDocumentsPagedCallable()
Returns a list of documents.
Type | Description |
UnaryCallable<ListDocumentsRequest,ListDocumentsPagedResponse> |
listenCallable()
public BidiStreamingCallable<ListenRequest,ListenResponse> listenCallable()
Returns a bi-directional watch stream.
Type | Description |
BidiStreamingCallable<ListenRequest,ListenResponse> |
partitionQueryPagedCallable()
public UnaryCallable<PartitionQueryRequest,FirestoreClient.PartitionQueryPagedResponse> partitionQueryPagedCallable()
Type | Description |
UnaryCallable<PartitionQueryRequest,PartitionQueryPagedResponse> |
rollbackCallable()
public UnaryCallable<RollbackRequest,Empty> rollbackCallable()
Rolls back a transaction.
Type | Description |
UnaryCallable<RollbackRequest,Empty> |
runAggregationQueryCallable()
public ServerStreamingCallable<RunAggregationQueryRequest,RunAggregationQueryResponse> runAggregationQueryCallable()
Runs an aggregation query.
Type | Description |
ServerStreamingCallable<RunAggregationQueryRequest,RunAggregationQueryResponse> |
runQueryCallable()
public ServerStreamingCallable<RunQueryRequest,RunQueryResponse> runQueryCallable()
Runs a query.
Type | Description |
ServerStreamingCallable<RunQueryRequest,RunQueryResponse> |
shutdown()
public void shutdown()
shutdownNow()
public void shutdownNow()