Slack320.java

public class Slack320 {
    public static void main(String[] args) {
        MeterRegistry registry = SampleRegistries.graphite();
        Counter counter = registry.counter("serviceName", "client",
                "token", "statistic", "timeout_connect");

        RandomEngine r = new MersenneTwister64(0);
        Normal dist = new Normal(0, 1, r);

        Flux.interval(Duration.ofMillis(10))
                .doOnEach(d -> {
                    if (dist.nextDouble() + 0.1 > 0) {
                        counter.increment();
                    }
                })
                .blockLast();
    }
}