[ML] APM Latency Correlations: Code consolidation.

x-pack/plugins/apm/common/search_strategies/constants.ts

@@ -0,0 +1,14 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0; you may not use this file except in compliance with the Elastic License
+ * 2.0.
+ */
+
+export const APM_SEARCH_STRATEGIES = {
+  APM_FAILED_TRANSACTIONS_CORRELATIONS: 'apmFailedTransactionsCorrelations',
+  APM_LATENCY_CORRELATIONS: 'apmLatencyCorrelations',
+} as const;
+export type ApmSearchStrategies = typeof APM_SEARCH_STRATEGIES[keyof typeof APM_SEARCH_STRATEGIES];
+
+export const DEFAULT_PERCENTILE_THRESHOLD = 95;

x-pack/plugins/apm/common/search_strategies/failure_correlations/constants.ts → x-pack/plugins/apm/common/search_strategies/failed_transactions_correlations/constants.ts

@@ -7,9 +7,6 @@
 
 import { i18n } from '@kbn/i18n';
 
-export const FAILED_TRANSACTIONS_CORRELATION_SEARCH_STRATEGY =
-  'apmFailedTransactionsCorrelationsSearchStrategy';
-
 export const FAILED_TRANSACTIONS_IMPACT_THRESHOLD = {
   HIGH: i18n.translate(
     'xpack.apm.correlations.failedTransactions.highImpactText',

x-pack/plugins/apm/common/search_strategies/failed_transactions_correlations/types.ts

@@ -0,0 +1,40 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0; you may not use this file except in compliance with the Elastic License
+ * 2.0.
+ */
+
+import { RawResponseBase, SearchStrategyClientParams } from '../types';
+
+import { FAILED_TRANSACTIONS_IMPACT_THRESHOLD } from './constants';
+
+export interface FailedTransactionsCorrelation {
+  key: string;
+  doc_count: number;
+  bg_count: number;
+  score: number;
+  pValue: number | null;
+  fieldName: string;
+  fieldValue: string;
+  normalizedScore: number;
+  failurePercentage: number;
+  successPercentage: number;
+}
+
+// Basic type guard for array of FailedTransactionsCorrelation
+export const isFailedTransactionsCorrelations = (
+  arg: unknown
+): arg is FailedTransactionsCorrelation[] => {
+  return Array.isArray(arg) && arg.length > 0;
+};
+
+export type FailedTransactionsCorrelationsImpactThreshold = typeof FAILED_TRANSACTIONS_IMPACT_THRESHOLD[keyof typeof FAILED_TRANSACTIONS_IMPACT_THRESHOLD];
+
+export type FailedTransactionsCorrelationsParams = SearchStrategyClientParams;
+
+export interface FailedTransactionsCorrelationsRawResponse
+  extends RawResponseBase {
+  log: string[];
+  failedTransactionsCorrelations: FailedTransactionsCorrelation[];
+}

x-pack/plugins/apm/common/search_strategies/latency_correlations/types.ts

@@ -0,0 +1,48 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0; you may not use this file except in compliance with the Elastic License
+ * 2.0.
+ */
+
+import {
+  HistogramItem,
+  RawResponseBase,
+  SearchStrategyClientParams,
+} from '../types';
+
+export interface LatencyCorrelation {
+  correlation: number;
+  fieldName: string;
+  fieldValue: string;
+  histogram: HistogramItem[];
+  ksTest: number;
+}
+
+// Basic type guard for array of LatencyCorrelation
+export function isLatencyCorrelations(
+  arg: unknown
+): arg is LatencyCorrelation[] {
+  return Array.isArray(arg) && arg.length > 0;
+}
+
+export interface AsyncSearchProviderProgress {
+  started: number;
+  loadedHistogramStepsize: number;
+  loadedOverallHistogram: number;
+  loadedFieldCanditates: number;
+  loadedFieldValuePairs: number;
+  loadedHistograms: number;
+}
+
+export interface LatencyCorrelationsParams extends SearchStrategyClientParams {
+  percentileThreshold: number;
+  analyzeCorrelations: boolean;
+}
+
+export interface LatencyCorrelationsRawResponse extends RawResponseBase {
+  log: string[];
+  overallHistogram?: HistogramItem[];
+  percentileThresholdValue?: number;
+  latencyCorrelations?: LatencyCorrelation[];
+}

x-pack/plugins/apm/common/search_strategies/types.ts

@@ -0,0 +1,47 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0; you may not use this file except in compliance with the Elastic License
+ * 2.0.
+ */
+
+export interface FieldValuePair {
+  fieldName: string;
+  fieldValue: string;
+}
+
+export interface HistogramItem {
+  key: number;
+  doc_count: number;
+}
+
+export interface ResponseHitSource {
+  [s: string]: unknown;
+}
+
+export interface ResponseHit {
+  _source: ResponseHitSource;
+}
+
+export interface RawResponseBase {
+  ccsWarning: boolean;
+  took: number;
+}
+
+export interface SearchStrategyClientParams {
+  environment: string;
+  kuery: string;
+  serviceName?: string;
+  transactionName?: string;
+  transactionType?: string;
+  start?: string;
+  end?: string;
+}
+
+export interface SearchStrategyServerParams {
+  index: string;
+  includeFrozen?: boolean;
+}
+
+export type SearchStrategyParams = SearchStrategyClientParams &
+  SearchStrategyServerParams;

x-pack/plugins/apm/public/components/app/correlations/correlations_table.tsx

@@ -14,11 +14,11 @@ import type { Criteria } from '@elastic/eui/src/components/basic_table/basic_tab
 import { FETCH_STATUS } from '../../../hooks/use_fetcher';
 import { useUiTracker } from '../../../../../observability/public';
 import { useTheme } from '../../../hooks/use_theme';
-import type { CorrelationsTerm } from '../../../../common/search_strategies/failure_correlations/types';
+import type { FieldValuePair } from '../../../../common/search_strategies/types';
 
 const PAGINATION_SIZE_OPTIONS = [5, 10, 20, 50];
 
-export type SelectedCorrelationTerm<T extends CorrelationsTerm> = Pick<
+export type SelectedCorrelationTerm<T extends FieldValuePair> = Pick<
   T,
   'fieldName' | 'fieldValue'
 >;
@@ -35,7 +35,7 @@ interface Props<T> {
   sorting?: EuiTableSortingType<T>;
 }
 
-export function CorrelationsTable<T extends CorrelationsTerm>({
+export function CorrelationsTable<T extends FieldValuePair>({
   significantTerms,
   status,
   setSelectedSignificantTerm,