@@ -117,8 +117,8 @@ public void sumAndMaxForGroup() {
117
117
EvalPayload payload = evaluator .eval (0L , data ("foo" , 1.0 , 2.0 , 3.0 ));
118
118
119
119
List <EvalPayload .Metric > metrics = new ArrayList <>();
120
- metrics .add (new EvalPayload .Metric ("max" , Collections . emptyMap ( ), 3.0 ));
121
- metrics .add (new EvalPayload .Metric ("sum" , Collections . emptyMap ( ), 6.0 ));
120
+ metrics .add (new EvalPayload .Metric ("max" , tags ( "name" , "unknown" ), 3.0 ));
121
+ metrics .add (new EvalPayload .Metric ("sum" , tags ( "name" , "unknown" ), 6.0 ));
122
122
EvalPayload expected = new EvalPayload (0L , metrics );
123
123
Assertions .assertEquals (expected , sort (payload ));
124
124
}
@@ -133,7 +133,7 @@ public void updateSub() {
133
133
evaluator .sync (sumSub );
134
134
EvalPayload payload = evaluator .eval (0L , data ("foo" , 1.0 , 2.0 , 3.0 ));
135
135
List <EvalPayload .Metric > metrics = new ArrayList <>();
136
- metrics .add (new EvalPayload .Metric ("sum" , Collections . emptyMap ( ), 6.0 ));
136
+ metrics .add (new EvalPayload .Metric ("sum" , tags ( "name" , "unknown" ), 6.0 ));
137
137
EvalPayload expected = new EvalPayload (0L , metrics );
138
138
Assertions .assertEquals (expected , payload );
139
139
@@ -143,7 +143,7 @@ public void updateSub() {
143
143
evaluator .sync (maxSub );
144
144
payload = evaluator .eval (0L , data ("foo" , 1.0 , 2.0 , 3.0 ));
145
145
metrics = new ArrayList <>();
146
- metrics .add (new EvalPayload .Metric ("sum" , Collections . emptyMap ( ), 3.0 ));
146
+ metrics .add (new EvalPayload .Metric ("sum" , tags ( "name" , "unknown" ), 3.0 ));
147
147
expected = new EvalPayload (0L , metrics );
148
148
Assertions .assertEquals (expected , payload );
149
149
}
@@ -212,7 +212,7 @@ public void delayAggrCounterSum() {
212
212
213
213
Assertions .assertEquals (1 , payload .getMetrics ().size ());
214
214
Assertions .assertEquals (
215
- new EvalPayload .Metric ("sum" , tags (), 6.0 ),
215
+ new EvalPayload .Metric ("sum" , tags ("name" , "unknown" ), 6.0 ),
216
216
payload .getMetrics ().get (0 )
217
217
);
218
218
}
@@ -229,7 +229,7 @@ public void delayAggrGaugeSum() {
229
229
Assertions .assertEquals (3 , payload .getMetrics ().size ());
230
230
for (EvalPayload .Metric m : payload .getMetrics ()) {
231
231
Map <String , String > tags = m .getTags ();
232
- Assertions .assertEquals (1 , tags .size ());
232
+ Assertions .assertEquals (2 , tags .size ());
233
233
Assertions .assertTrue (tags .containsKey ("atlas.aggr" ));
234
234
}
235
235
}
@@ -247,7 +247,7 @@ public void delayAggrGaugeCount() {
247
247
Assertions .assertEquals (3 , payload .getMetrics ().size ());
248
248
for (EvalPayload .Metric m : payload .getMetrics ()) {
249
249
Map <String , String > tags = m .getTags ();
250
- Assertions .assertEquals (1 , tags .size ());
250
+ Assertions .assertEquals (2 , tags .size ());
251
251
Assertions .assertTrue (tags .containsKey ("atlas.aggr" ));
252
252
Assertions .assertEquals (1.0 , m .getValue ());
253
253
}
@@ -294,7 +294,7 @@ public void delayAggrGaugeMax() {
294
294
295
295
Assertions .assertEquals (1 , payload .getMetrics ().size ());
296
296
Assertions .assertEquals (
297
- new EvalPayload .Metric ("max" , tags (), 3.0 ),
297
+ new EvalPayload .Metric ("max" , tags ("name" , "unknown" ), 3.0 ),
298
298
payload .getMetrics ().get (0 )
299
299
);
300
300
}
0 commit comments