Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Metrics UI] Correct inaccurate offsetting for non-rate aggregations inside of metrics threshold alerts #106947

Merged
merged 8 commits into from
Jul 28, 2021
Merged

[Metrics UI] Correct inaccurate offsetting for non-rate aggregations inside of metrics threshold alerts #106947

Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
fb27ec8
Don't skip last bucket for most aggs
phillipb Jul 27, 2021
d646204
Allow alerting on partial buckets for certain aggs
phillipb Jul 28, 2021
5616385
Fix test, PR feedback, and some comments
phillipb Jul 28, 2021
6087cfe
Remove all offset logic for date_range aggs
phillipb Jul 28, 2021
fa48ef8
Remove code comment
phillipb Jul 28, 2021
bbee8be
Add delivery delay
phillipb Jul 28, 2021
a47ba28
Fix the date range for query
phillipb Jul 28, 2021
59524a8
Add TODO
phillipb Jul 28, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 8 additions & 4 deletions x-pack/plugins/infra/server/lib/alerting/metric_threshold/lib/metric_query.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,8 @@ export const getElasticsearchMetricQuery = (
const to = timeframe.end;
const from = timeframe.start;

const deliveryDelay = 60 * 1000; // INFO: This allows us to account for any delay ES has in indexing the most recent data.

const aggregations =
aggType === Aggregators.COUNT
? {}
Expand Down Expand Up @@ -74,10 +76,12 @@ export const getElasticsearchMetricQuery = (
aggregatedIntervals: {
date_range: {
field: timefield,
ranges: Array.from(Array(Math.floor((to - from) / intervalAsMS)), (_, i) => ({
from: from + intervalAsMS * i,
to: from + intervalAsMS * (i + 1),
})),
ranges: [
{
from: from - intervalAsMS,
phillipb marked this conversation as resolved.
Show resolved Hide resolved
to: from + intervalAsMS - deliveryDelay,
},
],
},
aggregations,
},
Expand Down