Class Metrics

core/src/main/java/io/questdb/Metrics.java:49–174

import org.jetbrains.annotations.NotNull;

public class Metrics implements Target, Mutable {
    public static final Metrics DISABLED = new Metrics(false, new NullMetricsRegistry());
    public static final Metrics ENABLED = new Metrics(true, new MetricsRegistryImpl());
    private final GCMetrics gcMetrics;
    private final HealthMetricsImpl healthCheck;
    private final HttpMetrics httpMetrics;
    private final JsonQueryMetrics jsonQueryMetrics;
    private final LineMetrics lineMetrics;
    private final MetricsRegistry metricsRegistry;
    private final PGMetrics pgMetrics;
    private final QwpEgressMetrics qwpEgressMetrics;
    private final Runtime runtime = Runtime.getRuntime();
    private final VirtualLongGauge.StatProvider jvmFreeMemRef = runtime::freeMemory;
    private final VirtualLongGauge.StatProvider jvmMaxMemRef = runtime::maxMemory;
    private final VirtualLongGauge.StatProvider jvmTotalMemRef = runtime::totalMemory;
    private final TableWriterMetrics tableWriterMetrics;
    private final WalMetrics walMetrics;
    private final WorkerMetrics workerMetrics;
    private boolean enabled;

    public Metrics(boolean enabled, MetricsRegistry metricsRegistry) {
        this.enabled = enabled;
        this.gcMetrics = new GCMetrics();
        this.jsonQueryMetrics = new JsonQueryMetrics(metricsRegistry);
        this.httpMetrics = new HttpMetrics(metricsRegistry);
        this.pgMetrics = new PGMetrics(metricsRegistry);
        this.qwpEgressMetrics = new QwpEgressMetrics(metricsRegistry);
        this.lineMetrics = new LineMetrics(metricsRegistry);
        this.healthCheck = new HealthMetricsImpl(metricsRegistry);
        this.tableWriterMetrics = new TableWriterMetrics(metricsRegistry);
        this.walMetrics = new WalMetrics(metricsRegistry);
        createMemoryGauges(metricsRegistry);
        this.metricsRegistry = metricsRegistry;
        this.workerMetrics = new WorkerMetrics(metricsRegistry);
    }

    @Override
    public void clear() {
        gcMetrics.clear();
        jsonQueryMetrics.clear();
        pgMetrics.clear();
        qwpEgressMetrics.clear();
        lineMetrics.clear();
        healthCheck.clear();
        tableWriterMetrics.clear();
        walMetrics.clear();
        workerMetrics.clear();
        httpMetrics.clear();
        enabled = true;
    }

    public void disable() {
        enabled = false;
    }

    public MetricsRegistry getRegistry() {
        return metricsRegistry;
    }