Getting latency results

package.json

@@ -43,6 +43,7 @@
   "dependencies": {
     "@google-cloud/promisify": "^4.0.0",
     "arrify": "^2.0.1",
+    "async-mutex": "^0.4.0",
     "concat-stream": "^2.0.0",
     "extend": "^3.0.2",
     "google-gax": "^4.0.5",

src/request.ts

@@ -44,7 +44,7 @@
   KeyProto,
   ResponseResult,
   Entities,
   ValueProto,
 } from './entity';
 import {
   Query,
@@ -546,6 +546,18 @@
       );
   }
 
+  /**
+   * Datastore allows you to run aggregate queries by aggregate field.
+   *
+   * The query is run, and the results are returned as the second argument to
+   * your callback.
+   *
+   * @param {AggregateQuery} query AggregateQuery object.
+   * @param {RunQueryOptions} options Optional configuration
+   * @param {function} [callback] The callback function. If omitted, a promise is
+   * returned.
+   *
+   **/
   runAggregationQuery(
     query: AggregateQuery,
     options?: RunQueryOptions
@@ -596,9 +608,9 @@
           const results = res.batch.aggregationResults;
           const finalResults = results
             .map(
               (aggregationResult: any) => aggregationResult.aggregateProperties
             )
             .map((aggregateProperties: any) =>
               Object.fromEntries(
                 new Map(
                   Object.keys(aggregateProperties).map(key => [
@@ -933,7 +945,7 @@
     callback?: SaveCallback
   ): void | Promise<CommitResponse> {
     const transaction = this.datastore.transaction();
     transaction.run(async (err: any) => {
       if (err) {
         try {
           await transaction.rollback();