Skip to content

Commit

Permalink
space
Browse files Browse the repository at this point in the history
  • Loading branch information
smith committed Feb 22, 2021
1 parent f0fa80b commit e864f75
Show file tree
Hide file tree
Showing 24 changed files with 50 additions and 50 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import { ESFilter } from '../../../../../../typings/elasticsearch';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import {
EVENT_OUTCOME,
Expand Down Expand Up @@ -58,7 +58,7 @@ export async function getCorrelationsForFailedTransactions({
{ term: { [PROCESSOR_EVENT]: ProcessorEvent.transaction } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
];

if (serviceName) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import { ESFilter } from '../../../../../../typings/elasticsearch';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import {
SERVICE_NAME,
Expand Down Expand Up @@ -52,7 +52,7 @@ export async function getCorrelationsForSlowTransactions({
{ term: { [PROCESSOR_EVENT]: ProcessorEvent.transaction } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
];

if (serviceName) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import { ProcessorEvent } from '../../../../common/processor_event';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import { withApmSpan } from '../../../utils/with_apm_span';
import { Setup, SetupTimeRange } from '../../helpers/setup_request';
Expand All @@ -40,7 +40,7 @@ export async function getBuckets({
{ term: { [SERVICE_NAME]: serviceName } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
];

if (groupId) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import { ProcessorEvent } from '../../../common/processor_event';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../server/utils/queries';
import { withApmSpan } from '../../utils/with_apm_span';
import { Setup, SetupTimeRange } from '../helpers/setup_request';
Expand Down Expand Up @@ -49,7 +49,7 @@ export function getErrorGroupSample({
{ term: { [ERROR_GROUP_ID]: groupId } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
should: [{ term: { [TRANSACTION_SAMPLED]: true } }],
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import { ProcessorEvent } from '../../../../common/processor_event';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import { withApmSpan } from '../../../utils/with_apm_span';
import { getBucketSize } from '../../helpers/get_bucket_size';
Expand Down Expand Up @@ -58,7 +58,7 @@ export async function getServiceErrorGroupComparisonStatistics({
{ term: { [TRANSACTION_TYPE]: transactionType } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
},
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ import { ProcessorEvent } from '../../../../common/processor_event';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import { withApmSpan } from '../../../utils/with_apm_span';
import { getErrorName } from '../../helpers/get_error_name';
Expand Down Expand Up @@ -52,7 +52,7 @@ export function getServiceErrorGroupPrimaryStatistics({
{ term: { [TRANSACTION_TYPE]: transactionType } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
},
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ import { PromiseReturnType } from '../../../../../observability/typings/common';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import { ProcessorEvent } from '../../../../common/processor_event';
import {
Expand Down Expand Up @@ -73,7 +73,7 @@ export async function getServiceErrorGroups({
{ term: { [TRANSACTION_TYPE]: transactionType } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
},
},
Expand Down Expand Up @@ -156,7 +156,7 @@ export async function getServiceErrorGroups({
{ term: { [TRANSACTION_TYPE]: transactionType } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
},
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import { AggregationOptionsByType } from '../../../../../../typings/elasticsearc
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import { SERVICE_NODE_NAME_MISSING } from '../../../../common/service_nodes';
import {
Expand Down Expand Up @@ -104,7 +104,7 @@ export async function getServiceInstanceSystemMetricStats({
{ term: { [SERVICE_NAME]: serviceName } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
should: [cgroupMemoryFilter, systemMemoryFilter, cpuUsageFilter],
minimum_should_match: 1,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import { EventOutcome } from '../../../../common/event_outcome';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import { SERVICE_NODE_NAME_MISSING } from '../../../../common/service_nodes';
import {
Expand Down Expand Up @@ -83,7 +83,7 @@ export async function getServiceInstanceTransactionStats({
{ term: { [TRANSACTION_TYPE]: transactionType } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
},
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ import { LatencyAggregationType } from '../../../common/latency_aggregation_type
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../server/utils/queries';
import { Coordinate } from '../../../typings/timeseries';
import { withApmSpan } from '../../utils/with_apm_span';
Expand Down Expand Up @@ -95,7 +95,7 @@ export async function getServiceTransactionGroupComparisonStatistics({
),
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
},
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import { LatencyAggregationType } from '../../../common/latency_aggregation_type
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../server/utils/queries';
import { withApmSpan } from '../../utils/with_apm_span';
import {
Expand Down Expand Up @@ -83,7 +83,7 @@ export async function getServiceTransactionGroups({
),
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
},
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ import {
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import { AgentName } from '../../../../typings/es_schemas/ui/fields/agent';
import {
Expand Down Expand Up @@ -84,7 +84,7 @@ export async function getServiceTransactionStats({
),
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
},
},
Expand Down
4 changes: 2 additions & 2 deletions x-pack/plugins/apm/server/lib/services/get_throughput.ts
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import {
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../server/utils/queries';
import {
getDocumentTypeFilterForAggregatedTransactions,
Expand Down Expand Up @@ -54,7 +54,7 @@ function fetcher({
),
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
];

const params = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ import { EventOutcome } from '../../../common/event_outcome';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../server/utils/queries';
import {
getDocumentTypeFilterForAggregatedTransactions,
Expand Down Expand Up @@ -77,7 +77,7 @@ export async function getErrorRate({
),
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
];

const outcomes = getOutcomeAggregation();
Expand Down
4 changes: 2 additions & 2 deletions x-pack/plugins/apm/server/lib/transactions/breakdown/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ import { Setup, SetupTimeRange } from '../../helpers/setup_request';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import { getMetricsDateHistogramParams } from '../../helpers/metrics';
import { MAX_KPIS } from './constants';
Expand Down Expand Up @@ -92,7 +92,7 @@ export function getTransactionBreakdown({
{ term: { [TRANSACTION_TYPE]: transactionType } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
];

if (transactionName) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ import { joinByKey } from '../../../../../common/utils/join_by_key';
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../../server/utils/queries';
import {
getDocumentTypeFilterForAggregatedTransactions,
Expand Down Expand Up @@ -85,7 +85,7 @@ export async function getBuckets({
{ term: { [TRANSACTION_NAME]: transactionName } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
];

async function getSamplesForDistributionBuckets() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ import {
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import { withApmSpan } from '../../../utils/with_apm_span';

Expand Down Expand Up @@ -60,7 +60,7 @@ export async function getDistributionMax({
{ term: { [TRANSACTION_NAME]: transactionName } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
},
},
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import { LatencyAggregationType } from '../../../../common/latency_aggregation_t
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import {
getDocumentTypeFilterForAggregatedTransactions,
Expand Down Expand Up @@ -63,7 +63,7 @@ function searchLatency({
),
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
];

if (transactionName) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ import {
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../../../server/utils/queries';
import {
getDocumentTypeFilterForAggregatedTransactions,
Expand Down Expand Up @@ -60,7 +60,7 @@ function searchThroughput({
),
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
];

if (transactionName) {
Expand Down
4 changes: 2 additions & 2 deletions x-pack/plugins/apm/server/projections/errors.ts
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import {
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../server/utils/queries';
import { ProcessorEvent } from '../../common/processor_event';

Expand Down Expand Up @@ -41,7 +41,7 @@ export function getErrorGroupsProjection({
{ term: { [SERVICE_NAME]: serviceName } },
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
],
},
},
Expand Down
4 changes: 2 additions & 2 deletions x-pack/plugins/apm/server/projections/metrics.ts
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import {
import {
environmentQuery,
rangeQuery,
searchQuery,
kqlQuery,
} from '../../server/utils/queries';
import { SERVICE_NODE_NAME_MISSING } from '../../common/service_nodes';
import { ProcessorEvent } from '../../common/processor_event';
Expand Down Expand Up @@ -50,7 +50,7 @@ export function getMetricsProjection({
...getServiceNodeNameFilters(serviceNodeName),
...rangeQuery(start, end),
...environmentQuery(environment),
...searchQuery(kuery),
...kqlQuery(kuery),
];

return {
Expand Down
Loading

0 comments on commit e864f75

Please sign in to comment.