Skip to content

Commit

Permalink
Make DynatraceMeterRegistryTest more robust
Browse files Browse the repository at this point in the history
fixes gh-2821
  • Loading branch information
jonatan-ivanov committed Oct 14, 2021
1 parent 0caaccb commit ae67de5
Showing 1 changed file with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,7 @@
class DynatraceMeterRegistryTest {
private static final MockLoggerFactory FACTORY = new MockLoggerFactory();
private static final MockLogger LOGGER = FACTORY.getLogger(DynatraceMeterRegistry.class);
private static final Double GAUGE_VALUE = 1.0;

private final DynatraceConfig config = new DynatraceConfig() {
@Override
Expand Down Expand Up @@ -161,7 +162,7 @@ void putCustomMetricOnSuccessShouldAddMetricIdToCreatedCustomMetrics() throws No

@Test
void writeMeterWithGauge() {
meterRegistry.gauge("my.gauge", 1d);
meterRegistry.gauge("my.gauge", GAUGE_VALUE);
Gauge gauge = meterRegistry.find("my.gauge").gauge();
assertThat(meterRegistry.writeMeter(gauge)).hasSize(1);
}
Expand All @@ -177,7 +178,7 @@ void writeMeterWithGaugeShouldDropNanValue() {
@Test
void writeMeterWithGaugeWhenChangingFiniteToNaNShouldWork() {
AtomicBoolean first = new AtomicBoolean(true);
meterRegistry.gauge("my.gauge", first, (b) -> b.getAndSet(false) ? 1d : Double.NaN);
meterRegistry.gauge("my.gauge", first, (b) -> b.getAndSet(false) ? GAUGE_VALUE : Double.NaN);
Gauge gauge = meterRegistry.find("my.gauge").gauge();
Stream<DynatraceMeterRegistry.DynatraceCustomMetric> stream = meterRegistry.writeMeter(gauge);
List<DynatraceMeterRegistry.DynatraceCustomMetric> metrics = stream.collect(Collectors.toList());
Expand All @@ -187,7 +188,7 @@ void writeMeterWithGaugeWhenChangingFiniteToNaNShouldWork() {
try {
Map<String, Object> map = mapper.readValue(timeSeries.asJson(), Map.class);
List<List<Number>> dataPoints = (List<List<Number>>) map.get("dataPoints");
assertThat(dataPoints.get(0).get(1).doubleValue()).isEqualTo(1d);
assertThat(dataPoints.get(0).get(1).doubleValue()).isEqualTo(GAUGE_VALUE);
} catch (IOException ex) {
throw new RuntimeException(ex);
}
Expand All @@ -206,7 +207,7 @@ void writeMeterWithGaugeShouldDropInfiniteValues() {

@Test
void writeMeterWithTimeGauge() {
AtomicReference<Double> obj = new AtomicReference<>(1d);
AtomicReference<Double> obj = new AtomicReference<>(GAUGE_VALUE);
meterRegistry.more().timeGauge("my.timeGauge", Tags.empty(), obj, TimeUnit.SECONDS, AtomicReference::get);
TimeGauge timeGauge = meterRegistry.find("my.timeGauge").timeGauge();
assertThat(meterRegistry.writeMeter(timeGauge)).hasSize(1);
Expand Down Expand Up @@ -235,8 +236,7 @@ void writeMeterWithTimeGaugeShouldDropInfiniteValues() {

@Test
void writeCustomMetrics() {
Double number = 1d;
meterRegistry.gauge("my.gauge", number);
meterRegistry.gauge("my.gauge", GAUGE_VALUE);
Gauge gauge = meterRegistry.find("my.gauge").gauge();
Stream<DynatraceMeterRegistry.DynatraceCustomMetric> series = meterRegistry.writeMeter(gauge);
List<DynatraceTimeSeries> timeSeries = series
Expand Down Expand Up @@ -334,7 +334,7 @@ void failOnPutShouldHaveProperLogging() {
HttpSender httpClient = request -> new HttpSender.Response(500, "simulated");
DynatraceMeterRegistry meterRegistry = FACTORY.injectLogger(() -> createRegistry(httpClient));

meterRegistry.gauge("my.gauge", 1d);
meterRegistry.gauge("my.gauge", GAUGE_VALUE);
meterRegistry.publish();
Gauge gauge = meterRegistry.find("my.gauge").gauge();
assertThat(meterRegistry.writeMeter(gauge)).hasSize(1);
Expand All @@ -358,7 +358,7 @@ void failOnPostShouldHaveProperLogging() throws Throwable {

DynatraceMeterRegistry meterRegistry = FACTORY.injectLogger(() -> createRegistry(httpClient));

meterRegistry.gauge("my.gauge", 1d);
meterRegistry.gauge("my.gauge", GAUGE_VALUE);
meterRegistry.publish();
Gauge gauge = meterRegistry.find("my.gauge").gauge();
assertThat(meterRegistry.writeMeter(gauge)).hasSize(1);
Expand Down

0 comments on commit ae67de5

Please sign in to comment.