iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

BAEL-2670: update test class

Browse Source
This commit is contained in:
sharifi 2021-07-07 16:37:51 +04:30
parent a6ffc87f60
commit 9c27a90786
1 changed files with 54 additions and 53 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

107
metrics/src/test/java/com/baeldung/metrics/micrometer/MicrometerAtlasIntegrationTest.java
View File

@ -1,11 +1,7 @@
package com.baeldung.metrics.micrometer; package com.baeldung.metrics.micrometer;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.within;
import static org.assertj.core.api.Assertions.withinPercentage;
import static org.hamcrest.CoreMatchers.allOf;
import static org.hamcrest.CoreMatchers.equalTo; import static org.hamcrest.CoreMatchers.equalTo;
import static org.hamcrest.collection.IsMapContaining.hasEntry;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertThat; import static org.junit.Assert.assertThat;
import static org.junit.Assert.assertTrue; import static org.junit.Assert.assertTrue;
@ -16,29 +12,25 @@ import io.micrometer.core.instrument.DistributionSummary;
import io.micrometer.core.instrument.Gauge; import io.micrometer.core.instrument.Gauge;
import io.micrometer.core.instrument.LongTaskTimer; import io.micrometer.core.instrument.LongTaskTimer;
import io.micrometer.core.instrument.Measurement; import io.micrometer.core.instrument.Measurement;
import io.micrometer.core.instrument.Meter.Type;
import io.micrometer.core.instrument.MeterRegistry;
import io.micrometer.core.instrument.Metrics; import io.micrometer.core.instrument.Metrics;
import io.micrometer.core.instrument.Tag;
import io.micrometer.core.instrument.Timer; import io.micrometer.core.instrument.Timer;
import io.micrometer.core.instrument.composite.CompositeMeterRegistry; import io.micrometer.core.instrument.composite.CompositeMeterRegistry;
import io.micrometer.core.instrument.distribution.HistogramSnapshot;
import io.micrometer.core.instrument.distribution.ValueAtPercentile;
import io.micrometer.core.instrument.simple.SimpleMeterRegistry; import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
import io.micrometer.core.instrument.stats.hist.Histogram;
import io.micrometer.core.instrument.stats.quantile.WindowSketchQuantiles;
import java.time.Duration; import java.time.Duration;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
import java.util.Arrays;
import java.util.Map; import java.util.Map;
import java.util.TreeMap;
import java.util.Optional; import java.util.Optional;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import org.assertj.core.data.Percentage;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import org.junit.jupiter.api.Assertions;
import com.netflix.spectator.atlas.AtlasConfig; import com.netflix.spectator.atlas.AtlasConfig;
@ -55,7 +47,7 @@ public class MicrometerAtlasIntegrationTest {
@Override @Override
public Duration step() { public Duration step() {
return Duration.ofSeconds(1); return Duration.ofSeconds(10);
} }
@Override @Override
@ -77,9 +69,9 @@ public class MicrometerAtlasIntegrationTest {
compositeRegistry.gauge("baeldung.heat", 90); compositeRegistry.gauge("baeldung.heat", 90);
Optional<Gauge> oneGauge = oneSimpleMeter Optional<Gauge> oneGauge = Optional.ofNullable(oneSimpleMeter
.find("baeldung.heat") .find("baeldung.heat")
.gauge(); .gauge());
assertTrue(oneGauge.isPresent()); assertTrue(oneGauge.isPresent());
Iterator<Measurement> measurements = oneGauge Iterator<Measurement> measurements = oneGauge
.get() .get()
@ -91,9 +83,9 @@ public class MicrometerAtlasIntegrationTest {
.next() .next()
.getValue(), equalTo(90.00)); .getValue(), equalTo(90.00));
Optional<Gauge> atlasGauge = atlasMeterRegistry Optional<Gauge> atlasGauge = Optional.ofNullable(atlasMeterRegistry
.find("baeldung.heat") .find("baeldung.heat")
.gauge(); .gauge());
assertTrue(atlasGauge.isPresent()); assertTrue(atlasGauge.isPresent());
Iterator<Measurement> anotherMeasurements = atlasGauge Iterator<Measurement> anotherMeasurements = atlasGauge
.get() .get()
@ -122,9 +114,9 @@ public class MicrometerAtlasIntegrationTest {
.increment(); .increment();
new CountedObject(); new CountedObject();
Optional<Counter> counterOptional = Metrics.globalRegistry Optional<Counter> counterOptional = Optional.ofNullable(Metrics.globalRegistry
.find("objects.instance") .find("objects.instance")
.counter(); .counter());
assertTrue(counterOptional.isPresent()); assertTrue(counterOptional.isPresent());
assertTrue(counterOptional assertTrue(counterOptional
@ -145,7 +137,7 @@ public class MicrometerAtlasIntegrationTest {
assertTrue(counter.count() == 2); assertTrue(counter.count() == 2);
counter.increment(-1); counter.increment(-1);
assertTrue(counter.count() == 2); assertTrue(counter.count() == 1);
} }
@Test @Test
@ -162,7 +154,7 @@ public class MicrometerAtlasIntegrationTest {
timer.record(30, TimeUnit.MILLISECONDS); timer.record(30, TimeUnit.MILLISECONDS);
assertTrue(2 == timer.count()); assertTrue(2 == timer.count());
assertThat(timer.totalTime(TimeUnit.MILLISECONDS)).isBetween(40.0, 55.0); assertThat(timer.totalTime(TimeUnit.MILLISECONDS)).isBetween(40.0, 55.0);
} }
@ -173,12 +165,12 @@ public class MicrometerAtlasIntegrationTest {
.builder("3rdPartyService") .builder("3rdPartyService")
.register(registry); .register(registry);
long currentTaskId = longTaskTimer.start(); LongTaskTimer.Sample currentTaskId = longTaskTimer.start();
try { try {
TimeUnit.MILLISECONDS.sleep(2); TimeUnit.MILLISECONDS.sleep(2);
} catch (InterruptedException ignored) { } catch (InterruptedException ignored) {
} }
long timeElapsed = longTaskTimer.stop(currentTaskId); long timeElapsed = currentTaskId.stop();
assertEquals(2L, timeElapsed/((int) 1e6),1L); assertEquals(2L, timeElapsed/((int) 1e6),1L);
} }
@ -213,13 +205,12 @@ public class MicrometerAtlasIntegrationTest {
} }
@Test @Test
public void givenTimer_whenEnrichWithQuantile_thenQuantilesComputed() { public void givenTimer_whenEnrichWithPercentile_thenPercentilesComputed() {
SimpleMeterRegistry registry = new SimpleMeterRegistry(); SimpleMeterRegistry registry = new SimpleMeterRegistry();
Timer timer = Timer Timer timer = Timer
.builder("test.timer") .builder("test.timer")
.quantiles(WindowSketchQuantiles .publishPercentiles(0.3, 0.5, 0.95)
.quantiles(0.3, 0.5, 0.95) .publishPercentileHistogram()
.create())
.register(registry); .register(registry);
timer.record(2, TimeUnit.SECONDS); timer.record(2, TimeUnit.SECONDS);
@ -229,27 +220,18 @@ public class MicrometerAtlasIntegrationTest {
timer.record(8, TimeUnit.SECONDS); timer.record(8, TimeUnit.SECONDS);
timer.record(13, TimeUnit.SECONDS); timer.record(13, TimeUnit.SECONDS);
Map<String, Integer> quantileMap = extractTagValueMap(registry, Type.Gauge, 1e9); Map<Double, Double> expectedMicrometer = new TreeMap<>();
assertThat(quantileMap, allOf(hasEntry("quantile=0.3", 2), hasEntry("quantile=0.5", 3), hasEntry("quantile=0.95", 8))); expectedMicrometer.put(0.3, 1946.157056);
} expectedMicrometer.put(0.5, 3019.89888);
expectedMicrometer.put(0.95, 13354.663936);
private Map<String, Integer> extractTagValueMap(MeterRegistry registry, Type meterType, double valueDivisor) { Map<Double, Double> actualMicrometer = new TreeMap<>();
return registry ValueAtPercentile[] percentiles = timer.takeSnapshot().percentileValues();
.getMeters() for (ValueAtPercentile percentile : percentiles) {
.stream() actualMicrometer.put(percentile.percentile(), percentile.value(TimeUnit.MILLISECONDS));
.filter(meter -> meter.getType() == meterType) }
.collect(Collectors.toMap(meter -> {
Tag tag = meter assertEquals(expectedMicrometer, actualMicrometer);
.getId()
.getTags()
.iterator()
.next();
return tag.getKey() + "=" + tag.getValue();
}, meter -> (int) (meter
.measure()
.iterator()
.next()
.getValue() / valueDivisor)));
} }
@Test @Test
@ -257,7 +239,7 @@ public class MicrometerAtlasIntegrationTest {
SimpleMeterRegistry registry = new SimpleMeterRegistry(); SimpleMeterRegistry registry = new SimpleMeterRegistry();
DistributionSummary hist = DistributionSummary DistributionSummary hist = DistributionSummary
.builder("summary") .builder("summary")
.histogram(Histogram.linear(0, 10, 5)) .serviceLevelObjectives(1, 10, 5)
.register(registry); .register(registry);
hist.record(3); hist.record(3);
@ -267,17 +249,28 @@ public class MicrometerAtlasIntegrationTest {
hist.record(13); hist.record(13);
hist.record(26); hist.record(26);
Map<String, Integer> histograms = extractTagValueMap(registry, Type.Counter, 1.0); Map<Integer, Double> expectedMicrometer = new TreeMap<>();
expectedMicrometer.put(1,0D);
expectedMicrometer.put(10,2D);
expectedMicrometer.put(5,1D);
assertThat(histograms, allOf(hasEntry("bucket=0.0", 0), hasEntry("bucket=10.0", 2), hasEntry("bucket=20.0", 2), hasEntry("bucket=30.0", 1), hasEntry("bucket=40.0", 1), hasEntry("bucket=Infinity", 0))); Map<Integer, Double> actualMicrometer = new TreeMap<>();
HistogramSnapshot snapshot = hist.takeSnapshot();
Arrays.stream(snapshot.histogramCounts()).forEach(p -> {
actualMicrometer.put((Integer.valueOf((int) p.bucket())), p.count());
});
assertEquals(expectedMicrometer, actualMicrometer);
} }
@Test @Test
public void givenTimer_whenEnrichWithTimescaleHistogram_thenTimeScaleDataCollected() { public void givenTimer_whenEnrichWithTimescaleHistogram_thenTimeScaleDataCollected() {
SimpleMeterRegistry registry = new SimpleMeterRegistry(); SimpleMeterRegistry registry = new SimpleMeterRegistry();
Duration[] durations = {Duration.ofMillis(25), Duration.ofMillis(300), Duration.ofMillis(600)};
Timer timer = Timer Timer timer = Timer
.builder("timer") .builder("timer")
.histogram(Histogram.linearTime(TimeUnit.MILLISECONDS, 0, 200, 3)) .sla(durations)
.publishPercentileHistogram()
.register(registry); .register(registry);
timer.record(1000, TimeUnit.MILLISECONDS); timer.record(1000, TimeUnit.MILLISECONDS);
@ -286,10 +279,18 @@ public class MicrometerAtlasIntegrationTest {
timer.record(341, TimeUnit.MILLISECONDS); timer.record(341, TimeUnit.MILLISECONDS);
timer.record(500, TimeUnit.MILLISECONDS); timer.record(500, TimeUnit.MILLISECONDS);
Map<String, Integer> histograms = extractTagValueMap(registry, Type.Counter, 1.0); Map<Double, Double> expectedMicrometer = new TreeMap<>();
expectedMicrometer.put(2.5E7,1D);
expectedMicrometer.put(3.0E8,1D);
expectedMicrometer.put(6.0E8,4D);
assertThat(histograms, allOf(hasEntry("bucket=0.0", 0), hasEntry("bucket=2.0E8", 1), hasEntry("bucket=4.0E8", 1), hasEntry("bucket=Infinity", 3))); Map<Double, Double> actualMicrometer = new TreeMap<>();
HistogramSnapshot snapshot = timer.takeSnapshot();
Arrays.stream(snapshot.histogramCounts()).forEach(p -> {
actualMicrometer.put((Double.valueOf((int) p.bucket())), p.count());
});
assertEquals(expectedMicrometer, actualMicrometer);
} }
} }