Method Telemetry

core/src/main/java/io/questdb/Telemetry.java:82–111

(TelemetryTypeBuilder<T> builder, CairoConfiguration configuration)

    private TableWriter writer;

    public Telemetry(TelemetryTypeBuilder<T> builder, CairoConfiguration configuration) {
        TelemetryType<T> type = builder.build(configuration);
        final TelemetryConfiguration telemetryConfiguration = type.getTelemetryConfiguration(configuration);
        enabled = telemetryConfiguration.getEnabled();
        maxFileNameLen = configuration.getMaxFileNameLength();
        if (enabled) {
            telemetryType = type;
            clock = configuration.getMicrosecondClock();
            dbSizeEstimateTimeout = telemetryConfiguration.getDbSizeEstimateTimeout() * 1000;
            telemetryQueue = new RingQueue<>(type.getTaskFactory(), telemetryConfiguration.getQueueCapacity());
            telemetryPubSeq = new MPSequence(telemetryQueue.getCycle());
            telemetrySubSeq = new SCSequence();
            telemetryPubSeq.then(telemetrySubSeq).then(telemetryPubSeq);
            ttlWeeks = telemetryConfiguration.getTtlWeeks();
            ThrottleInterval = telemetryConfiguration.getThrottleIntervalMicros();
            lastEventTimestamps = new IntLongHashMap();
            taskConsumer = ThrottleInterval > 0 ? this::consumeThrottled : this::consumeDirect;
        } else {
            telemetryType = null;
            clock = null;
            dbSizeEstimateTimeout = 0;
            telemetryQueue = null;
            telemetryPubSeq = null;
            telemetrySubSeq = null;
            lastEventTimestamps = null;
            ttlWeeks = 0;
            ThrottleInterval = 0;
            taskConsumer = null;
        }
    }

    public void clear() {
        if (writer != null) {