[APM] fixes incorrect values in service overview throughput chart

x-pack/plugins/apm/server/lib/helpers/get_tpm_rate.ts

@@ -0,0 +1,12 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { SetupTimeRange } from './setup_request';
+
+export function getTpmRate({ start, end }: SetupTimeRange, eventCount: number) {
+  const durationAsMinutes = (end - start) / 1000 / 60;
+  return eventCount / durationAsMinutes;
+}

x-pack/plugins/apm/server/lib/observability_overview/get_transaction_coordinates.ts

@@ -15,6 +15,7 @@ import {
   getProcessorEventForAggregatedTransactions,
   getTransactionDurationFieldForAggregatedTransactions,
 } from '../helpers/aggregated_transactions';
+import { getTpmRate } from '../helpers/get_tpm_rate';
 
 export async function getTransactionCoordinates({
   setup,
@@ -63,12 +64,10 @@ export async function getTransactionCoordinates({
     },
   });
 
-  const deltaAsMinutes = (end - start) / 1000 / 60;
-
   return (
     aggregations?.distribution.buckets.map((bucket) => ({
       x: bucket.key,
-      y: bucket.count.value / deltaAsMinutes,
+      y: getTpmRate(setup, bucket.count.value),
     })) || []
   );
 }

x-pack/plugins/apm/server/lib/services/get_service_dependencies/index.ts

@@ -13,6 +13,7 @@ import { joinByKey } from '../../../../common/utils/join_by_key';
 import { Setup, SetupTimeRange } from '../../helpers/setup_request';
 import { getMetrics } from './get_metrics';
 import { getDestinationMap } from './get_destination_map';
+import { getTpmRate } from '../../helpers/get_tpm_rate';
 
 export type ServiceDependencyItem = {
   name: string;
@@ -50,8 +51,6 @@ export async function getServiceDependencies({
   environment: string;
   numBuckets: number;
 }): Promise<ServiceDependencyItem[]> {
-  const { start, end } = setup;
-
   const [allMetrics, destinationMap] = await Promise.all([
     getMetrics({
       setup,
@@ -134,8 +133,6 @@ export async function getServiceDependencies({
       }
     );
 
-    const deltaAsMinutes = (end - start) / 60 / 1000;
-
     const destMetrics = {
       latency: {
         value:
@@ -150,11 +147,11 @@ export async function getServiceDependencies({
       throughput: {
         value:
           mergedMetrics.value.count > 0
-            ? mergedMetrics.value.count / deltaAsMinutes
+            ? getTpmRate(setup, mergedMetrics.value.count)
             : null,
         timeseries: mergedMetrics.timeseries.map((point) => ({
           x: point.x,
-          y: point.count > 0 ? point.count / deltaAsMinutes : null,
+          y: point.count > 0 ? getTpmRate(setup, point.count) : null,
         })),
       },
       errorRate: {

x-pack/plugins/apm/server/lib/services/get_service_instances/get_service_instance_transaction_stats.ts

@@ -19,6 +19,7 @@ import {
   getProcessorEventForAggregatedTransactions,
   getTransactionDurationFieldForAggregatedTransactions,
 } from '../../helpers/aggregated_transactions';
+import { getTpmRate } from '../../helpers/get_tpm_rate';
 
 export async function getServiceInstanceTransactionStats({
   setup,
@@ -112,8 +113,6 @@ export async function getServiceInstanceTransactionStats({
     },
   });
 
-  const deltaAsMinutes = (end - start) / 60 / 1000;
-
   return (
     response.aggregations?.[SERVICE_NODE_NAME].buckets.map(
       (serviceNodeBucket) => {
@@ -135,10 +134,10 @@ export async function getServiceInstanceTransactionStats({
             })),
           },
           throughput: {
-            value: count.value / deltaAsMinutes,
+            value: getTpmRate(setup, count.value),
             timeseries: timeseries.buckets.map((dateBucket) => ({
               x: dateBucket.key,
-              y: dateBucket.count.value / deltaAsMinutes,
+              y: getTpmRate(setup, dateBucket.count.value),
             })),
           },
           latency: {

x-pack/plugins/apm/server/lib/services/get_service_transaction_groups/get_transaction_groups_for_page.ts

@@ -25,6 +25,7 @@ import {
   getLatencyAggregation,
   getLatencyValue,
 } from '../../helpers/latency_aggregation_type';
+import { getTpmRate } from '../../helpers/get_tpm_rate';
 
 export type ServiceOverviewTransactionGroupSortField =
   | 'name'
@@ -64,8 +65,6 @@ export async function getTransactionGroupsForPage({
   transactionType: string;
   latencyAggregationType: LatencyAggregationType;
 }) {
-  const deltaAsMinutes = (end - start) / 1000 / 60;
-
   const field = getTransactionDurationFieldForAggregatedTransactions(
     searchAggregatedTransactions
   );
@@ -124,7 +123,7 @@ export async function getTransactionGroupsForPage({
           latencyAggregationType,
           aggregation: bucket.latency,
         }),
-        throughput: bucket.transaction_count.value / deltaAsMinutes,
+        throughput: getTpmRate({ start, end }, bucket.transaction_count.value),
         errorRate,
       };
     }) ?? [];

x-pack/plugins/apm/server/lib/services/get_service_transaction_groups/merge_transaction_group_data.ts

@@ -6,6 +6,7 @@
 
 import { EVENT_OUTCOME } from '../../../../common/elasticsearch_fieldnames';
 import { LatencyAggregationType } from '../../../../common/latency_aggregation_types';
+import { getTpmRate } from '../../helpers/get_tpm_rate';
 import { getLatencyValue } from '../../helpers/latency_aggregation_type';
 import { TransactionGroupTimeseriesData } from './get_timeseries_data_for_transaction_groups';
 import { TransactionGroupWithoutTimeseriesData } from './get_transaction_groups_for_page';
@@ -25,8 +26,6 @@ export function mergeTransactionGroupData({
   latencyAggregationType: LatencyAggregationType;
   transactionType: string;
 }) {
-  const deltaAsMinutes = (end - start) / 1000 / 60;
-
   return transactionGroups.map((transactionGroup) => {
     const groupBucket = timeseriesData.find(
       ({ key }) => key === transactionGroup.name
@@ -52,7 +51,7 @@ export function mergeTransactionGroupData({
             ...acc.throughput,
             timeseries: acc.throughput.timeseries.concat({
               x: point.key,
-              y: point.transaction_count.value / deltaAsMinutes,
+              y: getTpmRate({ start, end }, point.transaction_count.value),
             }),
           },
           errorRate: {

x-pack/plugins/apm/server/lib/services/get_services/get_service_transaction_stats.ts

@@ -22,6 +22,7 @@ import {
   getTransactionDurationFieldForAggregatedTransactions,
 } from '../../helpers/aggregated_transactions';
 import { getBucketSize } from '../../helpers/get_bucket_size';
+import { getTpmRate } from '../../helpers/get_tpm_rate';
 import {
   calculateTransactionErrorPercentage,
   getOutcomeAggregation,
@@ -35,16 +36,6 @@ interface AggregationParams {
 
 const MAX_NUMBER_OF_SERVICES = 500;
 
-function calculateAvgDuration({
-  value,
-  deltaAsMinutes,
-}: {
-  value: number;
-  deltaAsMinutes: number;
-}) {
-  return value / deltaAsMinutes;
-}
-
 export async function getServiceTransactionStats({
   setup,
   searchAggregatedTransactions,
@@ -139,8 +130,6 @@ export async function getServiceTransactionStats({
     },
   });
 
-  const deltaAsMinutes = (setup.end - setup.start) / 1000 / 60;
-
   return (
     response.aggregations?.services.buckets.map((bucket) => {
       const topTransactionTypeBucket =
@@ -179,17 +168,14 @@ export async function getServiceTransactionStats({
           ),
         },
         transactionsPerMinute: {
-          value: calculateAvgDuration({
-            value: topTransactionTypeBucket.real_document_count.value,
-            deltaAsMinutes,
-          }),
+          value: getTpmRate(
+            setup,
+            topTransactionTypeBucket.real_document_count.value
+          ),
           timeseries: topTransactionTypeBucket.timeseries.buckets.map(
             (dateBucket) => ({
               x: dateBucket.key,
-              y: calculateAvgDuration({
-                value: dateBucket.real_document_count.value,
-                deltaAsMinutes,
-              }),
+              y: getTpmRate(setup, dateBucket.real_document_count.value),
             })
           ),
         },

x-pack/plugins/apm/server/lib/services/get_throughput.ts

@@ -16,6 +16,7 @@ import {
   getProcessorEventForAggregatedTransactions,
 } from '../helpers/aggregated_transactions';
 import { getBucketSize } from '../helpers/get_bucket_size';
+import { getTpmRate } from '../helpers/get_tpm_rate';
 import { Setup, SetupTimeRange } from '../helpers/setup_request';
 
 interface Options {
@@ -27,12 +28,15 @@ interface Options {
 
 type ESResponse = PromiseReturnType<typeof fetcher>;
 
-function transform(response: ESResponse) {
+function transform(options: Options, response: ESResponse) {
   if (response.hits.total.value === 0) {
     return [];
   }
   const buckets = response.aggregations?.throughput.buckets ?? [];
-  return buckets.map(({ key: x, doc_count: y }) => ({ x, y }));
+  return buckets.map(({ key: x, doc_count: y }) => ({
+    x,
+    y: getTpmRate(options.setup, y),
+  }));
 }
 
 async function fetcher({
@@ -82,6 +86,6 @@ async function fetcher({
 
 export async function getThroughput(options: Options) {
   return {
-    throughput: transform(await fetcher(options)),
+    throughput: transform(options, await fetcher(options)),
   };
 }

x-pack/plugins/apm/server/lib/transactions/get_throughput_charts/index.ts

@@ -106,9 +106,7 @@ export async function getThroughputCharts({
   setup: Setup & SetupTimeRange;
   searchAggregatedTransactions: boolean;
 }) {
-  const { start, end } = setup;
-  const { bucketSize, intervalString } = getBucketSize({ start, end });
-  const durationAsMinutes = (end - start) / 1000 / 60;
+  const { bucketSize, intervalString } = getBucketSize(setup);
 
   const response = await searchThroughput({
     serviceName,
@@ -123,7 +121,7 @@ export async function getThroughputCharts({
     throughputTimeseries: getThroughputBuckets({
       throughputResultBuckets: response.aggregations?.throughput.buckets,
       bucketSize,
-      durationAsMinutes,
+      setupTimeRange: setup,
     }),
   };
 }

x-pack/plugins/apm/server/lib/transactions/get_throughput_charts/transform.ts

@@ -7,17 +7,19 @@
 import { sortBy } from 'lodash';
 import { NOT_AVAILABLE_LABEL } from '../../../../common/i18n';
 import { ThroughputChartsResponse } from '.';
+import { getTpmRate } from '../../helpers/get_tpm_rate';
+import { SetupTimeRange } from '../../helpers/setup_request';
 
 type ThroughputResultBuckets = Required<ThroughputChartsResponse>['aggregations']['throughput']['buckets'];
 
 export function getThroughputBuckets({
   throughputResultBuckets = [],
   bucketSize,
-  durationAsMinutes,
+  setupTimeRange,
 }: {
   throughputResultBuckets?: ThroughputResultBuckets;
   bucketSize: number;
-  durationAsMinutes: number;
+  setupTimeRange: SetupTimeRange;
 }) {
   const buckets = throughputResultBuckets.map(
     ({ key: resultKey, timeseries }) => {
@@ -38,7 +40,7 @@ export function getThroughputBuckets({
         .reduce((a, b) => a + b, 0);
 
       // calculate average throughput
-      const avg = docCountTotal / durationAsMinutes;
+      const avg = getTpmRate(setupTimeRange, docCountTotal);
 
       return { key, dataPoints, avg };
     }