Skip to content

Instantly share code, notes, and snippets.

@jkschneider
Created February 6, 2018 04:44
Show Gist options
  • Save jkschneider/61fc957cc494660522b13c736f99f34d to your computer and use it in GitHub Desktop.
Save jkschneider/61fc957cc494660522b13c736f99f34d to your computer and use it in GitHub Desktop.
Micrometer 354
package io.micrometer.core.samples;
import io.micrometer.core.instrument.MeterRegistry;
import io.micrometer.core.instrument.Tags;
import io.micrometer.core.instrument.binder.jvm.JvmMemoryMetrics;
import io.micrometer.core.samples.utils.SampleRegistries;
import reactor.core.publisher.Flux;
import java.time.Duration;
import java.util.concurrent.atomic.AtomicLong;
public class Micrometer354 {
public static void main(String[] args) {
MeterRegistry registry = SampleRegistries.datadogStatsd();
registry.gauge("meter.size", registry, r -> r.getMeters().size());
new JvmMemoryMetrics().bindTo(registry);
AtomicLong val = new AtomicLong(0);
Flux.interval(Duration.ofMillis(10))
.doOnEach(n -> {
registry.gauge("large.cardinality.gauge", Tags.of("name", n.toString()), val);
val.incrementAndGet();
})
.blockLast();
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment