Commit b1bcf5a
[Discover][Metrics] Telemetry for Metrics with multiple units (elastic#269484)
Supports
[elastic#5507](elastic/observability-dev#5507)
## Summary
This PR adds `multi_value_counts.units` to the `discover_metrics_info`
EBT payload so we can measure how often a METRICS_INFO row has more than
one unit (mixed units/rollovers), matching the existing
`data_streams`/`field_types`/`metric_types` counters.
### Changes
- Extended `MetricsTelemetry.multi_value_counts` with `units`.
- Increment `units` in `accumulate_metrics_row_telemetry` when
`units.length > 1`.
- Initialize `units: 0` in `createInitialMetricsTelemetry`.
- Register `multi_value_counts.units` in the discover_metrics_info EBT
schema.
- Updated unit tests and api_docs.
---------
Co-authored-by: Lucas Francisco López <lucaslopezf@gmail.com>1 parent cee796c commit b1bcf5a
8 files changed
Lines changed: 75 additions & 22 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
15 | | - | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
16 | 22 | | |
17 | 23 | | |
18 | 24 | | |
| |||
36 | 42 | | |
37 | 43 | | |
38 | 44 | | |
39 | | - | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
40 | 52 | | |
41 | 53 | | |
42 | 54 | | |
| |||
415 | 427 | | |
416 | 428 | | |
417 | 429 | | |
418 | | - | |
| 430 | + | |
419 | 431 | | |
420 | 432 | | |
421 | 433 | | |
| |||
428 | 440 | | |
429 | 441 | | |
430 | 442 | | |
431 | | - | |
| 443 | + | |
432 | 444 | | |
433 | 445 | | |
434 | 446 | | |
| |||
444 | 456 | | |
445 | 457 | | |
446 | 458 | | |
447 | | - | |
| 459 | + | |
448 | 460 | | |
449 | 461 | | |
450 | 462 | | |
| |||
467 | 479 | | |
468 | 480 | | |
469 | 481 | | |
470 | | - | |
| 482 | + | |
471 | 483 | | |
472 | 484 | | |
473 | 485 | | |
| |||
522 | 534 | | |
523 | 535 | | |
524 | 536 | | |
525 | | - | |
| 537 | + | |
526 | 538 | | |
527 | 539 | | |
528 | 540 | | |
| |||
538 | 550 | | |
539 | 551 | | |
540 | 552 | | |
541 | | - | |
| 553 | + | |
542 | 554 | | |
543 | 555 | | |
544 | 556 | | |
| |||
554 | 566 | | |
555 | 567 | | |
556 | 568 | | |
557 | | - | |
| 569 | + | |
558 | 570 | | |
559 | 571 | | |
560 | 572 | | |
| |||
695 | 707 | | |
696 | 708 | | |
697 | 709 | | |
698 | | - | |
| 710 | + | |
699 | 711 | | |
700 | 712 | | |
701 | 713 | | |
| |||
718 | 730 | | |
719 | 731 | | |
720 | 732 | | |
721 | | - | |
| 733 | + | |
722 | 734 | | |
723 | 735 | | |
724 | 736 | | |
| |||
741 | 753 | | |
742 | 754 | | |
743 | 755 | | |
744 | | - | |
| 756 | + | |
745 | 757 | | |
746 | 758 | | |
747 | 759 | | |
| |||
774 | 786 | | |
775 | 787 | | |
776 | 788 | | |
777 | | - | |
| 789 | + | |
778 | 790 | | |
779 | 791 | | |
780 | 792 | | |
| |||
796 | 808 | | |
797 | 809 | | |
798 | 810 | | |
799 | | - | |
| 811 | + | |
800 | 812 | | |
801 | 813 | | |
802 | 814 | | |
| |||
887 | 899 | | |
888 | 900 | | |
889 | 901 | | |
890 | | - | |
| 902 | + | |
| 903 | + | |
| 904 | + | |
| 905 | + | |
| 906 | + | |
| 907 | + | |
| 908 | + | |
891 | 909 | | |
892 | 910 | | |
893 | 911 | | |
| |||
1015 | 1033 | | |
1016 | 1034 | | |
1017 | 1035 | | |
1018 | | - | |
| 1036 | + | |
1019 | 1037 | | |
1020 | 1038 | | |
1021 | 1039 | | |
| |||
Lines changed: 2 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
81 | 81 | | |
82 | 82 | | |
83 | 83 | | |
84 | | - | |
| 84 | + | |
85 | 85 | | |
86 | 86 | | |
87 | 87 | | |
| |||
202 | 202 | | |
203 | 203 | | |
204 | 204 | | |
205 | | - | |
| 205 | + | |
206 | 206 | | |
207 | 207 | | |
208 | 208 | | |
| |||
Lines changed: 3 additions & 3 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
40 | 40 | | |
41 | 41 | | |
42 | 42 | | |
43 | | - | |
| 43 | + | |
44 | 44 | | |
45 | 45 | | |
46 | 46 | | |
| |||
59 | 59 | | |
60 | 60 | | |
61 | 61 | | |
62 | | - | |
| 62 | + | |
63 | 63 | | |
64 | 64 | | |
65 | 65 | | |
| |||
85 | 85 | | |
86 | 86 | | |
87 | 87 | | |
88 | | - | |
| 88 | + | |
89 | 89 | | |
90 | 90 | | |
91 | 91 | | |
Lines changed: 1 addition & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
22 | 22 | | |
23 | 23 | | |
24 | 24 | | |
| 25 | + | |
25 | 26 | | |
26 | 27 | | |
27 | 28 | | |
| |||
Lines changed: 6 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
58 | 58 | | |
59 | 59 | | |
60 | 60 | | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
61 | 67 | | |
62 | 68 | | |
63 | 69 | | |
| |||
Lines changed: 27 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
57 | 57 | | |
58 | 58 | | |
59 | 59 | | |
| 60 | + | |
60 | 61 | | |
61 | 62 | | |
62 | 63 | | |
| |||
95 | 96 | | |
96 | 97 | | |
97 | 98 | | |
| 99 | + | |
98 | 100 | | |
99 | 101 | | |
100 | 102 | | |
| |||
141 | 143 | | |
142 | 144 | | |
143 | 145 | | |
| 146 | + | |
144 | 147 | | |
145 | 148 | | |
146 | 149 | | |
| |||
179 | 182 | | |
180 | 183 | | |
181 | 184 | | |
| 185 | + | |
182 | 186 | | |
183 | 187 | | |
184 | 188 | | |
| |||
217 | 221 | | |
218 | 222 | | |
219 | 223 | | |
| 224 | + | |
220 | 225 | | |
221 | 226 | | |
222 | 227 | | |
223 | 228 | | |
224 | 229 | | |
| 230 | + | |
| 231 | + | |
| 232 | + | |
| 233 | + | |
| 234 | + | |
| 235 | + | |
| 236 | + | |
| 237 | + | |
| 238 | + | |
| 239 | + | |
| 240 | + | |
| 241 | + | |
| 242 | + | |
| 243 | + | |
| 244 | + | |
| 245 | + | |
| 246 | + | |
| 247 | + | |
| 248 | + | |
| 249 | + | |
| 250 | + | |
225 | 251 | | |
226 | 252 | | |
227 | 253 | | |
| |||
273 | 299 | | |
274 | 300 | | |
275 | 301 | | |
| 302 | + | |
276 | 303 | | |
277 | 304 | | |
278 | 305 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
29 | | - | |
| 29 | + | |
30 | 30 | | |
31 | 31 | | |
32 | 32 | | |
| |||
Lines changed: 1 addition & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
91 | 91 | | |
92 | 92 | | |
93 | 93 | | |
| 94 | + | |
94 | 95 | | |
95 | 96 | | |
96 | 97 | | |
| |||
0 commit comments