Skip to content

Commit

Permalink
fix types
Browse files Browse the repository at this point in the history
  • Loading branch information
walterra committed Jul 14, 2021
1 parent 9a39121 commit a39dcf8
Show file tree
Hide file tree
Showing 12 changed files with 29 additions and 31 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@ interface CorrelationsOptions {
}

interface RawResponse {
log: string[];
percentileThresholdValue?: number;
took: number;
values: SearchServiceValue[];
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ import * as t from 'io-ts';

import type { estypes } from '@elastic/elasticsearch';
import { TRANSACTION_DURATION } from '../../../../common/elasticsearch_fieldnames';
import type { SearchServiceParams } from '../../../../common/search_strategies/correlations/types';
import type { SearchServiceFetchParams } from '../../../../common/search_strategies/correlations/types';
import { rangeRt } from '../../../routes/default_api_types';

import { Setup, SetupTimeRange } from '../../helpers/setup_request';
Expand Down Expand Up @@ -43,7 +43,7 @@ export const getTermsQuery = (
};

interface QueryParams {
params: SearchServiceParams;
params: SearchServiceFetchParams;
fieldName?: string;
fieldValue?: string;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import type { estypes } from '@elastic/elasticsearch';
import type { ElasticsearchClient } from 'src/core/server';

import { TRANSACTION_DURATION } from '../../../../common/elasticsearch_fieldnames';
import type { SearchServiceParams } from '../../../../common/search_strategies/correlations/types';
import type { SearchServiceFetchParams } from '../../../../common/search_strategies/correlations/types';

import { getQueryWithParams } from './get_query_with_params';

Expand Down Expand Up @@ -40,7 +40,7 @@ export interface BucketCorrelation {
}

export const getTransactionDurationCorrelationRequest = (
params: SearchServiceParams,
params: SearchServiceFetchParams,
expectations: number[],
ranges: estypes.AggregationsAggregationRange[],
fractions: number[],
Expand Down Expand Up @@ -95,7 +95,7 @@ export const getTransactionDurationCorrelationRequest = (

export const fetchTransactionDurationCorrelation = async (
esClient: ElasticsearchClient,
params: SearchServiceParams,
params: SearchServiceFetchParams,
expectations: number[],
ranges: estypes.AggregationsAggregationRange[],
fractions: number[],
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import type { estypes } from '@elastic/elasticsearch';

import type { ElasticsearchClient } from 'src/core/server';

import type { SearchServiceParams } from '../../../../common/search_strategies/correlations/types';
import type { SearchServiceFetchParams } from '../../../../common/search_strategies/correlations/types';

import { getQueryWithParams } from './get_query_with_params';
import { Field } from './query_field_value_pairs';
Expand Down Expand Up @@ -37,7 +37,7 @@ export const hasPrefixToInclude = (fieldName: string) => {
};

export const getRandomDocsRequest = (
params: SearchServiceParams
params: SearchServiceFetchParams
): estypes.SearchRequest => ({
index: params.index,
body: {
Expand All @@ -56,7 +56,7 @@ export const getRandomDocsRequest = (

export const fetchTransactionDurationFieldCandidates = async (
esClient: ElasticsearchClient,
params: SearchServiceParams
params: SearchServiceFetchParams
): Promise<{ fieldCandidates: Field[] }> => {
const { index } = params;
// Get all fields with keyword mapping
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ import type { estypes } from '@elastic/elasticsearch';

import type {
AsyncSearchProviderProgress,
SearchServiceParams,
SearchServiceFetchParams,
} from '../../../../common/search_strategies/correlations/types';

import { getQueryWithParams } from './get_query_with_params';
Expand All @@ -26,7 +26,7 @@ type FieldValuePairs = FieldValuePair[];
export type Field = string;

export const getTermsAggRequest = (
params: SearchServiceParams,
params: SearchServiceFetchParams,
fieldName: string
): estypes.SearchRequest => ({
index: params.index,
Expand All @@ -46,7 +46,7 @@ export const getTermsAggRequest = (

export const fetchTransactionDurationFieldValuePairs = async (
esClient: ElasticsearchClient,
params: SearchServiceParams,
params: SearchServiceFetchParams,
fieldCandidates: Field[],
progress: AsyncSearchProviderProgress
): Promise<FieldValuePairs> => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,12 +7,12 @@

import { ElasticsearchClient } from 'kibana/server';
import { estypes } from '@elastic/elasticsearch';
import { SearchServiceParams } from '../../../../common/search_strategies/correlations/types';
import { SearchServiceFetchParams } from '../../../../common/search_strategies/correlations/types';
import { getQueryWithParams } from './get_query_with_params';
import { TRANSACTION_DURATION } from '../../../../common/elasticsearch_fieldnames';

export const getTransactionDurationRangesRequest = (
params: SearchServiceParams,
params: SearchServiceFetchParams,
ranges: estypes.AggregationsAggregationRange[]
): estypes.SearchRequest => ({
index: params.index,
Expand All @@ -35,7 +35,7 @@ export const getTransactionDurationRangesRequest = (
*/
export const fetchTransactionDurationFractions = async (
esClient: ElasticsearchClient,
params: SearchServiceParams,
params: SearchServiceFetchParams,
ranges: estypes.AggregationsAggregationRange[]
): Promise<{ fractions: number[]; totalDocCount: number }> => {
const resp = await esClient.search(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,13 +13,13 @@ import { TRANSACTION_DURATION } from '../../../../common/elasticsearch_fieldname
import type {
HistogramItem,
ResponseHit,
SearchServiceParams,
SearchServiceFetchParams,
} from '../../../../common/search_strategies/correlations/types';

import { getQueryWithParams } from './get_query_with_params';

export const getTransactionDurationHistogramRequest = (
params: SearchServiceParams,
params: SearchServiceFetchParams,
interval: number,
fieldName?: string,
fieldValue?: string
Expand All @@ -42,7 +42,7 @@ export const getTransactionDurationHistogramRequest = (

export const fetchTransactionDurationHistogram = async (
esClient: ElasticsearchClient,
params: SearchServiceParams,
params: SearchServiceFetchParams,
interval: number,
fieldName?: string,
fieldValue?: string
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,14 +10,14 @@ import type { estypes } from '@elastic/elasticsearch';
import type { ElasticsearchClient } from 'src/core/server';

import { TRANSACTION_DURATION } from '../../../../common/elasticsearch_fieldnames';
import type { SearchServiceParams } from '../../../../common/search_strategies/correlations/types';
import type { SearchServiceFetchParams } from '../../../../common/search_strategies/correlations/types';

import { getQueryWithParams } from './get_query_with_params';

const HISTOGRAM_INTERVALS = 1000;

export const getHistogramIntervalRequest = (
params: SearchServiceParams
params: SearchServiceFetchParams
): estypes.SearchRequest => ({
index: params.index,
body: {
Expand All @@ -32,7 +32,7 @@ export const getHistogramIntervalRequest = (

export const fetchTransactionDurationHistogramInterval = async (
esClient: ElasticsearchClient,
params: SearchServiceParams
params: SearchServiceFetchParams
): Promise<number> => {
const resp = await esClient.search(getHistogramIntervalRequest(params));

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ import type { estypes } from '@elastic/elasticsearch';
import type { ElasticsearchClient } from 'src/core/server';

import { TRANSACTION_DURATION } from '../../../../common/elasticsearch_fieldnames';
import type { SearchServiceParams } from '../../../../common/search_strategies/correlations/types';
import type { SearchServiceFetchParams } from '../../../../common/search_strategies/correlations/types';

import { getQueryWithParams } from './get_query_with_params';

Expand All @@ -32,7 +32,7 @@ const getHistogramRangeSteps = (min: number, max: number, steps: number) => {
};

export const getHistogramIntervalRequest = (
params: SearchServiceParams
params: SearchServiceFetchParams
): estypes.SearchRequest => ({
index: params.index,
body: {
Expand All @@ -47,7 +47,7 @@ export const getHistogramIntervalRequest = (

export const fetchTransactionDurationHistogramRangeSteps = async (
esClient: ElasticsearchClient,
params: SearchServiceParams
params: SearchServiceFetchParams
): Promise<number[]> => {
const steps = 100;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import type { estypes } from '@elastic/elasticsearch';
import type { ElasticsearchClient } from 'src/core/server';

import { TRANSACTION_DURATION } from '../../../../common/elasticsearch_fieldnames';
import type { SearchServiceParams } from '../../../../common/search_strategies/correlations/types';
import type { SearchServiceFetchParams } from '../../../../common/search_strategies/correlations/types';

import { getQueryWithParams } from './get_query_with_params';
import { SIGNIFICANT_VALUE_DIGITS } from './constants';
Expand All @@ -28,7 +28,7 @@ interface ResponseHit {
}

export const getTransactionDurationPercentilesRequest = (
params: SearchServiceParams,
params: SearchServiceFetchParams,
percents?: number[],
fieldName?: string,
fieldValue?: string
Expand Down Expand Up @@ -58,7 +58,7 @@ export const getTransactionDurationPercentilesRequest = (

export const fetchTransactionDurationPercentiles = async (
esClient: ElasticsearchClient,
params: SearchServiceParams,
params: SearchServiceFetchParams,
percents?: number[],
fieldName?: string,
fieldValue?: string
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import type { estypes } from '@elastic/elasticsearch';
import type { ElasticsearchClient } from 'src/core/server';

import { TRANSACTION_DURATION } from '../../../../common/elasticsearch_fieldnames';
import type { SearchServiceParams } from '../../../../common/search_strategies/correlations/types';
import type { SearchServiceFetchParams } from '../../../../common/search_strategies/correlations/types';

import { getQueryWithParams } from './get_query_with_params';

Expand All @@ -27,7 +27,7 @@ interface ResponseHit {
}

export const getTransactionDurationRangesRequest = (
params: SearchServiceParams,
params: SearchServiceFetchParams,
rangesSteps: number[],
fieldName?: string,
fieldValue?: string
Expand Down Expand Up @@ -65,7 +65,7 @@ export const getTransactionDurationRangesRequest = (

export const fetchTransactionDurationRanges = async (
esClient: ElasticsearchClient,
params: SearchServiceParams,
params: SearchServiceFetchParams,
rangesSteps: number[],
fieldName?: string,
fieldValue?: string
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ export default function ApiTest({ getService }: FtrProviderContext) {
const getRequestBody = () => {
const partialSearchRequest: PartialSearchRequest = {
params: {
index: 'apm-*',
environment: 'ENVIRONMENT_ALL',
start: '2020',
end: '2021',
Expand Down

0 comments on commit a39dcf8

Please sign in to comment.