mirror of
https://github.com/elastic/kibana.git
synced 2025-04-24 09:48:58 -04:00
[APM] Require track_total_hits
param in ES request (#140938)
This commit is contained in:
parent
99cfd5a1b3
commit
e97158a265
96 changed files with 144 additions and 12 deletions
|
@ -74,6 +74,7 @@ export const getDestinationMap = ({
|
|||
events: [ProcessorEvent.span],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
@ -144,6 +145,7 @@ export const getDestinationMap = ({
|
|||
events: [ProcessorEvent.transaction],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
query: {
|
||||
bool: {
|
||||
filter: [
|
||||
|
|
|
@ -61,7 +61,7 @@ describe('APMEventClient', () => {
|
|||
apm: {
|
||||
events: [],
|
||||
},
|
||||
body: { size: 0 },
|
||||
body: { size: 0, track_total_hits: false },
|
||||
});
|
||||
|
||||
return res.ok({ body: 'ok' });
|
||||
|
|
|
@ -43,6 +43,7 @@ export type APMEventESSearchRequest = Omit<ESSearchRequest, 'index'> & {
|
|||
};
|
||||
body: {
|
||||
size: number;
|
||||
track_total_hits: boolean | number;
|
||||
};
|
||||
};
|
||||
|
||||
|
|
|
@ -15,6 +15,7 @@ describe('unpackProcessorEvents', () => {
|
|||
const request = {
|
||||
apm: { events: ['transaction', 'error'] },
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: { bool: { filter: [{ terms: { foo: 'bar' } }] } },
|
||||
},
|
||||
|
|
|
@ -53,6 +53,7 @@ export async function getHasAggregatedServicesMetrics({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
size: 1,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -102,7 +102,7 @@ describe('setupRequest', () => {
|
|||
const { apmEventClient } = await setupRequest(mockResources);
|
||||
await apmEventClient.search('foo', {
|
||||
apm: { events: [ProcessorEvent.transaction] },
|
||||
body: { size: 10 },
|
||||
body: { track_total_hits: 10_000, size: 10 },
|
||||
});
|
||||
|
||||
expect(
|
||||
|
@ -111,6 +111,7 @@ describe('setupRequest', () => {
|
|||
{
|
||||
index: ['apm-*'],
|
||||
body: {
|
||||
track_total_hits: 10000,
|
||||
size: 10,
|
||||
query: {
|
||||
bool: {
|
||||
|
@ -166,7 +167,7 @@ describe('with includeFrozen=false', () => {
|
|||
apm: {
|
||||
events: [],
|
||||
},
|
||||
body: { size: 10 },
|
||||
body: { track_total_hits: 10_000, size: 10 },
|
||||
});
|
||||
|
||||
const params =
|
||||
|
@ -188,7 +189,7 @@ describe('with includeFrozen=true', () => {
|
|||
|
||||
await apmEventClient.search('foo', {
|
||||
apm: { events: [] },
|
||||
body: { size: 10 },
|
||||
body: { track_total_hits: 10_000, size: 10 },
|
||||
});
|
||||
|
||||
const params =
|
||||
|
|
|
@ -78,6 +78,7 @@ export async function getIsUsingServiceDestinationMetrics({
|
|||
events: [getProcessorEventForServiceDestinationStatistics(true)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
size: 1,
|
||||
terminate_after: 1,
|
||||
query: {
|
||||
|
|
|
@ -32,8 +32,9 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 1,
|
||||
"terminate_after": 1,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
"terminate_after": 1,
|
||||
}
|
||||
`;
|
||||
|
||||
|
@ -57,8 +58,9 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 1,
|
||||
"terminate_after": 1,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
"terminate_after": 1,
|
||||
}
|
||||
`;
|
||||
|
||||
|
@ -85,8 +87,9 @@ Array [
|
|||
},
|
||||
},
|
||||
"size": 1,
|
||||
"terminate_after": 1,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
"terminate_after": 1,
|
||||
},
|
||||
],
|
||||
Array [
|
||||
|
@ -104,6 +107,7 @@ Array [
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
"terminate_after": 1,
|
||||
},
|
||||
|
|
|
@ -64,6 +64,7 @@ async function getHasTransactions({
|
|||
events: [ProcessorEvent.transaction],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -35,6 +35,8 @@ export async function getHasAggregatedTransactions({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
terminate_after: 1,
|
||||
size: 1,
|
||||
query: {
|
||||
bool: {
|
||||
|
@ -46,7 +48,6 @@ export async function getHasAggregatedTransactions({
|
|||
},
|
||||
},
|
||||
},
|
||||
terminate_after: 1,
|
||||
}
|
||||
);
|
||||
|
||||
|
|
|
@ -81,6 +81,7 @@ export async function getColdstartRate({
|
|||
events: [getProcessorEventForTransactions(searchAggregatedTransactions)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: { bool: { filter } },
|
||||
aggs: {
|
||||
|
|
|
@ -90,6 +90,7 @@ export async function getFailedTransactionRate({
|
|||
events: [getProcessorEventForTransactions(searchAggregatedTransactions)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: { bool: { filter } },
|
||||
aggs: {
|
||||
|
|
|
@ -87,7 +87,7 @@ export async function getTransactionDurationChartPreview({
|
|||
apm: {
|
||||
events: [getProcessorEventForTransactions(searchAggregatedTransactions)],
|
||||
},
|
||||
body: { size: 0, query, aggs },
|
||||
body: { size: 0, track_total_hits: false, query, aggs },
|
||||
};
|
||||
const resp = await apmEventClient.search(
|
||||
'get_transaction_duration_chart_preview',
|
||||
|
|
|
@ -47,7 +47,7 @@ export async function getTransactionErrorCountChartPreview({
|
|||
|
||||
const params = {
|
||||
apm: { events: [ProcessorEvent.error] },
|
||||
body: { size: 0, query, aggs },
|
||||
body: { size: 0, track_total_hits: false, query, aggs },
|
||||
};
|
||||
|
||||
const resp = await apmEventClient.search(
|
||||
|
|
|
@ -48,6 +48,7 @@ export async function getTransactionErrorRateChartPreview({
|
|||
events: [getProcessorEventForTransactions(searchAggregatedTransactions)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -47,6 +47,7 @@ export const fetchDurationCorrelation = async ({
|
|||
events: [eventType],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: getCommonCorrelationsQuery({
|
||||
start,
|
||||
|
|
|
@ -65,6 +65,7 @@ export const fetchDurationFieldCandidates = async ({
|
|||
events: [eventType],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
fields: ['*'],
|
||||
_source: false,
|
||||
query: getCommonCorrelationsQuery({
|
||||
|
|
|
@ -39,6 +39,7 @@ export const fetchDurationFractions = async ({
|
|||
events: [eventType],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: getCommonCorrelationsQuery({
|
||||
start,
|
||||
|
|
|
@ -75,6 +75,7 @@ export const fetchDurationHistogramRangeSteps = async ({
|
|||
events: [getEventType(chartType, searchMetrics)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
size: 0,
|
||||
query: getCommonCorrelationsQuery({
|
||||
start,
|
||||
|
|
|
@ -62,6 +62,7 @@ export const fetchDurationRanges = async ({
|
|||
events: [getEventType(chartType, searchMetrics)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: getCommonCorrelationsQuery({
|
||||
start,
|
||||
|
|
|
@ -53,6 +53,7 @@ export const fetchFailedEventsCorrelationPValues = async ({
|
|||
events: [eventType],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -42,6 +42,7 @@ export const fetchFieldValuePairs = async ({
|
|||
events: [eventType],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: getCommonCorrelationsQuery({
|
||||
start,
|
||||
|
|
|
@ -66,6 +66,7 @@ export async function getErrorRateChartsForDependency({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -63,6 +63,7 @@ export async function getLatencyChartsForDependency({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -31,6 +31,7 @@ export async function getMetadataForDependency({
|
|||
events: [ProcessorEvent.span],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 1,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -70,6 +70,7 @@ export async function getThroughputChartsForDependency({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -97,6 +97,7 @@ export async function getTopDependencyOperations({
|
|||
events: [ProcessorEvent.span],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -76,6 +76,7 @@ export async function getTopDependencySpans({
|
|||
events: [ProcessorEvent.span],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: MAX_NUM_SPANS,
|
||||
query: {
|
||||
bool: {
|
||||
|
@ -123,6 +124,7 @@ export async function getTopDependencySpans({
|
|||
events: [ProcessorEvent.transaction],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: transactionIds.length,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -31,6 +31,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -66,6 +67,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
|
|
@ -40,6 +40,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -79,6 +80,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
|
|
@ -50,6 +50,7 @@ export async function getAllEnvironments({
|
|||
// use timeout + min_doc_count to return as early as possible
|
||||
// if filter is not defined to prevent timeouts
|
||||
...(!serviceName ? { timeout: '1ms' } : {}),
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -50,6 +50,7 @@ export async function getEnvironments({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -53,6 +53,7 @@ Object {
|
|||
},
|
||||
},
|
||||
],
|
||||
"track_total_hits": true,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -116,6 +117,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -184,6 +186,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
|
|
@ -50,6 +50,7 @@ Array [
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
},
|
||||
],
|
||||
|
|
|
@ -42,6 +42,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -93,6 +94,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
|
|
@ -44,6 +44,7 @@ export async function getBuckets({
|
|||
events: [ProcessorEvent.error],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -70,6 +70,7 @@ async function getTopErroneousTransactions({
|
|||
events: [ProcessorEvent.error],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -65,6 +65,7 @@ export async function getErrorGroupDetailedStatistics({
|
|||
events: [ProcessorEvent.error],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -70,6 +70,7 @@ export async function getErrorGroupMainStatistics({
|
|||
events: [ProcessorEvent.error],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -41,6 +41,7 @@ export async function getErrorGroupSample({
|
|||
events: [ProcessorEvent.error as const],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: true,
|
||||
size: 1,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -52,6 +52,7 @@ export async function getEventMetadata({
|
|||
events: [processorEvent],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
query: {
|
||||
bool: { filter },
|
||||
},
|
||||
|
|
|
@ -22,6 +22,7 @@ export async function hasHistoricalAgentData(setup: Setup) {
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
size: 0,
|
||||
},
|
||||
};
|
||||
|
|
|
@ -38,6 +38,7 @@ export const getInfrastructureData = async ({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -89,6 +89,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -180,6 +181,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -338,6 +340,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -429,6 +432,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -510,6 +514,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -609,6 +614,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -706,6 +712,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -870,6 +877,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -967,6 +975,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -1054,6 +1063,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -1142,6 +1152,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -1228,6 +1239,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -1381,6 +1393,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -1467,6 +1480,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -1543,6 +1557,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
|
|
@ -65,6 +65,7 @@ export async function fetchAndTransformGcMetrics({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -53,6 +53,7 @@ export async function getActiveInstances({
|
|||
events: [getProcessorEventForTransactions(searchAggregatedTransactions)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -74,6 +74,7 @@ export async function getComputeUsage({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -92,6 +92,7 @@ export async function fetchAndTransformMetrics<T extends MetricAggs>({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -33,6 +33,7 @@ export async function getServiceCount({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -44,6 +44,7 @@ export async function getTransactionsPerMinute({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -21,6 +21,7 @@ export async function getHasData({ setup }: { setup: Setup }) {
|
|||
},
|
||||
terminate_after: 1,
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
size: 0,
|
||||
},
|
||||
};
|
||||
|
|
|
@ -35,6 +35,7 @@ export async function getServicesCounts({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 0,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -40,6 +40,7 @@ export async function lookupServices({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -33,6 +33,7 @@ export async function fetchServicePathsFromTraceIds(
|
|||
events: [ProcessorEvent.span, ProcessorEvent.transaction],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -116,6 +116,7 @@ async function getServicesData(
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -73,6 +73,7 @@ export function getServiceMapDependencyNodeInfo({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -174,6 +174,7 @@ async function getTransactionStats({
|
|||
events: [getProcessorEventForTransactions(searchAggregatedTransactions)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
@ -256,6 +257,7 @@ async function getCpuStats({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
@ -319,6 +321,7 @@ function getMemoryStats({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -80,6 +80,7 @@ export async function getTraceSampleIds({
|
|||
events,
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query,
|
||||
aggs: {
|
||||
|
|
|
@ -53,6 +53,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -116,6 +117,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -192,6 +194,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
|
|
@ -45,6 +45,7 @@ const getServiceNodes = async ({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -11,6 +11,7 @@ Object {
|
|||
},
|
||||
"body": Object {
|
||||
"size": 0,
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
"terminate_after": 1,
|
||||
}
|
||||
|
@ -66,6 +67,7 @@ Object {
|
|||
"order": "desc",
|
||||
},
|
||||
},
|
||||
"track_total_hits": 1,
|
||||
},
|
||||
"terminate_after": 1,
|
||||
}
|
||||
|
@ -152,6 +154,7 @@ Array [
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
},
|
||||
Object {
|
||||
|
@ -213,6 +216,7 @@ Array [
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
},
|
||||
]
|
||||
|
@ -255,6 +259,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
|
|
@ -52,6 +52,7 @@ export async function getDerivedServiceAnnotations({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
@ -83,6 +84,7 @@ export async function getDerivedServiceAnnotations({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 1,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -48,6 +48,7 @@ export async function getServiceAgent({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
size: 1,
|
||||
_source: [AGENT_NAME, SERVICE_RUNTIME_NAME],
|
||||
query: {
|
||||
|
|
|
@ -47,6 +47,7 @@ export async function getServiceInstanceMetadataDetails({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
terminate_after: 1,
|
||||
size: 1,
|
||||
query: {
|
||||
|
@ -69,6 +70,7 @@ export async function getServiceInstanceMetadataDetails({
|
|||
events: [ProcessorEvent.transaction],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
terminate_after: 1,
|
||||
size: 1,
|
||||
query: { bool: { filter } },
|
||||
|
@ -87,6 +89,7 @@ export async function getServiceInstanceMetadataDetails({
|
|||
events: [getProcessorEventForTransactions(true)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
terminate_after: 1,
|
||||
size: 1,
|
||||
query: {
|
||||
|
|
|
@ -145,6 +145,7 @@ export async function getServiceInstancesSystemMetricStatistics<
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -160,7 +160,7 @@ export async function getServiceInstancesTransactionStatistics<
|
|||
getProcessorEventForTransactions(searchAggregatedTransactions),
|
||||
],
|
||||
},
|
||||
body: { size: 0, query, aggs },
|
||||
body: { size: 0, track_total_hits: false, query, aggs },
|
||||
}
|
||||
);
|
||||
|
||||
|
|
|
@ -105,6 +105,7 @@ export async function getServiceMetadataDetails({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
size: 1,
|
||||
_source: [SERVICE, AGENT, HOST, CONTAINER, KUBERNETES, CLOUD],
|
||||
query: { bool: { filter, should } },
|
||||
|
|
|
@ -71,6 +71,7 @@ export async function getServiceMetadataIcons({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: 1,
|
||||
size: 1,
|
||||
_source: [
|
||||
KUBERNETES,
|
||||
|
|
|
@ -45,6 +45,7 @@ export async function getServiceNodeMetadata({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -93,6 +93,7 @@ export async function getServiceTransactionGroupDetailedStatistics({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -70,6 +70,7 @@ export async function getServiceTransactionGroups({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -36,6 +36,7 @@ export async function getServiceTransactionTypes({
|
|||
events: [getProcessorEventForTransactions(searchAggregatedTransactions)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -59,6 +59,7 @@ export async function getServiceAggregatedTransactionStats({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -78,6 +78,7 @@ export async function getServiceTransactionStats({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -47,6 +47,7 @@ export async function getServicesFromErrorAndMetricDocuments({
|
|||
events: [ProcessorEvent.metric, ProcessorEvent.error],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -82,6 +82,7 @@ export async function getServiceAggregatedTransactionDetailedStats({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -80,6 +80,7 @@ export async function getServiceTransactionDetailedStats({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -68,6 +68,7 @@ export async function getThroughput({
|
|||
events: [getProcessorEventForTransactions(searchAggregatedTransactions)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -115,6 +115,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
|
|
@ -29,6 +29,7 @@ export async function getAgentNameByService({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -43,6 +43,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 1,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
"terminate_after": 1,
|
||||
}
|
||||
|
@ -62,6 +63,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 1,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
"terminate_after": 1,
|
||||
}
|
||||
|
|
|
@ -37,6 +37,7 @@ export async function getTransaction({
|
|||
events: [ProcessorEvent.transaction as const],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 1,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -49,6 +49,7 @@ async function fetchLinkedChildrenOfSpan({
|
|||
},
|
||||
_source: [SPAN_LINKS, TRACE_ID, SPAN_ID, PROCESSOR_EVENT, TRANSACTION_ID],
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 1000,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -40,6 +40,7 @@ export async function getLinkedParentsOfSpan({
|
|||
},
|
||||
_source: [SPAN_LINKS],
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 1,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -68,6 +68,7 @@ async function fetchSpanLinksDetails({
|
|||
AGENT_NAME,
|
||||
],
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 1000,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -42,6 +42,7 @@ export async function getSuggestionsWithTermsAggregation({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
timeout: '1500ms',
|
||||
size: 0,
|
||||
query: {
|
||||
|
|
|
@ -38,6 +38,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 1000,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
|
|
@ -67,6 +67,7 @@ export async function getTopTracesPrimaryStats({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -36,6 +36,7 @@ export async function getTraceItems(
|
|||
events: [ProcessorEvent.error],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: maxTraceItems,
|
||||
query: {
|
||||
bool: {
|
||||
|
@ -54,6 +55,7 @@ export async function getTraceItems(
|
|||
events: [ProcessorEvent.span, ProcessorEvent.transaction],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: maxTraceItems + 1,
|
||||
size: maxTraceItems,
|
||||
query: {
|
||||
bool: {
|
||||
|
@ -71,7 +73,6 @@ export async function getTraceItems(
|
|||
{ [TRANSACTION_DURATION]: { order: 'desc' as const } },
|
||||
{ [SPAN_DURATION]: { order: 'desc' as const } },
|
||||
] as Sort,
|
||||
track_total_hits: true,
|
||||
},
|
||||
});
|
||||
|
||||
|
|
|
@ -54,6 +54,7 @@ export async function getTraceSamplesByQuery({
|
|||
],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
@ -121,6 +122,7 @@ export async function getTraceSamplesByQuery({
|
|||
events: [ProcessorEvent.transaction],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -25,6 +25,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 1,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -149,6 +150,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -278,6 +280,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 0,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
@ -343,6 +346,7 @@ Object {
|
|||
},
|
||||
},
|
||||
"size": 500,
|
||||
"track_total_hits": false,
|
||||
},
|
||||
}
|
||||
`;
|
||||
|
|
|
@ -98,6 +98,7 @@ export async function getTransactionBreakdown({
|
|||
events: [ProcessorEvent.metric],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -83,6 +83,7 @@ function searchLatency({
|
|||
events: [getProcessorEventForTransactions(searchAggregatedTransactions)],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 0,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -34,6 +34,7 @@ export async function getTransaction({
|
|||
events: [ProcessorEvent.transaction],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 1,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -23,6 +23,7 @@ export async function getRootTransactionByTraceId(
|
|||
events: [ProcessorEvent.transaction as const],
|
||||
},
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
size: 1,
|
||||
query: {
|
||||
bool: {
|
||||
|
|
|
@ -78,6 +78,7 @@ export async function getTraceSamples({
|
|||
},
|
||||
_source: [TRANSACTION_ID, TRACE_ID, '@timestamp'],
|
||||
body: {
|
||||
track_total_hits: false,
|
||||
query: {
|
||||
bool: {
|
||||
filter: [
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue