Class CounterImpl

core/src/main/java/io/questdb/metrics/CounterImpl.java:33–64

import java.util.concurrent.atomic.LongAdder;

public class CounterImpl implements Counter {
    private final LongAdder counter;
    private final CharSequence name;

    public CounterImpl(CharSequence name) {
        this.name = name;
        this.counter = new LongAdder();
    }

    @Override
    public void add(long value) {
        counter.add(value);
    }

    @Override
    public long getValue() {
        return counter.sum();
    }

    @Override
    public void reset() {
        counter.reset();
    }

    @Override
    public void scrapeIntoPrometheus(@NotNull BorrowableUtf8Sink sink) {
        PrometheusFormatUtils.appendCounterType(name, sink);
        PrometheusFormatUtils.appendCounterNamePrefix(name, sink);
        PrometheusFormatUtils.appendSampleLineSuffix(sink, counter.longValue());
        PrometheusFormatUtils.appendNewLine(sink);
    }
}