Micrometer 354

Micrometer354.java

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();
    }
}