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