github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-24 09:48:58 -04:00
Code Issues Projects Releases Packages Wiki Activity

[APM] Fix service metrics generator (#142790)

Browse source 
Co-authored-by: Kibana Machine <42973632+kibanamachine@users.noreply.github.com>
This commit is contained in:
Katerina Patticha 2022-10-10 11:32:04 +02:00 • committed by GitHub
parent 613930461e
commit 6ec4061a11
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 28 additions and 30 deletions
Download patch file Download diff file Expand all files Collapse all files

58
packages/kbn-apm-synthtrace/src/lib/apm/aggregators/service_metrics_aggregator.ts
View file

@ -34,21 +34,19 @@ export type ServiceFields = Fields &
| 'service.name'
| 'service.version'
| 'service.environment'
| 'transaction.type'
> &
Partial<{
_doc_count: number;
transaction: {
duration: {
summary: {
min: number;
max: number;
sum: number;
value_count: number;
};
};
failure_count: number;
success_count: number;
type: string;
'duration.summary': {
min: number;
max: number;
sum: number;
value_count: number;
};
};
}>;
@ -86,10 +84,10 @@ export class ServicMetricsAggregator implements StreamAggregator<ApmFields> {
},
},
failure_count: {
type: { type: 'long' },
type: 'long',
},
success_count: {
type: { type: 'long' },
type: 'long',
},
},
},
@ -141,22 +139,24 @@ export class ServicMetricsAggregator implements StreamAggregator<ApmFields> {
}
const state = this.state[key];
state.count++;
switch (event['event.outcome']) {
case 'failure':
state.failure_count++;
break;
case 'success':
state.success_count++;
break;
}
const duration = Number(event['transaction.duration.us']);
if (duration >= 0) {
state.count++;
state.sum += duration;
if (duration > state.max) state.max = duration;
if (duration < state.min) state.min = Math.min(0, duration);
switch (event['event.outcome']) {
case 'failure':
state.failure_count++;
break;
case 'success':
state.success_count++;
break;
}
}
};
@ -197,18 +197,16 @@ export class ServicMetricsAggregator implements StreamAggregator<ApmFields> {
'processor.event': 'metric',
'service.name': state['service.name'],
'service.environment': state['service.environment'],
'transaction.type': state['transaction.type'],
transaction: {
duration: {
summary: {
min: state.min,
max: state.max,
sum: state.sum,
value_count: state.count,
},
'duration.summary': {
min: state.min,
max: state.max,
sum: state.sum,
value_count: state.count,
},
failure_count: state.failure_count,
success_count: state.success_count,
failure_count: state.failure_count,
type: state['transaction.type'] ?? 'request',
},
};
}