SystemState.hpp

#pragma once
 
#include "util/config/ConfigDefinition.hpp"
#include "util/log/Logger.hpp"
#include "util/prometheus/Bool.hpp"
#include "util/prometheus/Label.hpp"
#include "util/prometheus/Prometheus.hpp"
 
#include <boost/signals2/signal.hpp>
#include <boost/signals2/variadic_signal.hpp>
 
#include <atomic>
#include <memory>
 
namespace etl {

struct SystemState {
    static std::shared_ptr<SystemState>
    makeSystemState(util::config::ClioConfigDefinition const& config)
    {
        auto state = std::make_shared<SystemState>();
        state->isStrictReadonly = config.get<bool>("read_only");
        return state;
    }

    util::prometheus::Bool isStrictReadonly = PrometheusService::boolMetric(
        "read_only",
        util::prometheus::Labels{},
        "Whether the process is in strict read-only mode"
    );

    util::prometheus::Bool isWriting = PrometheusService::boolMetric(
        "etl_writing",
        util::prometheus::Labels{},
        "Whether the process is writing to the database"
    );

    std::atomic_bool etlStarted{false};

    enum class WriteCommand {
        StartWriting, 
        StopWriting   
    };

    boost::signals2::signal<void(WriteCommand)> writeCommandSignal;

    util::prometheus::Bool isAmendmentBlocked = PrometheusService::boolMetric(
        "etl_amendment_blocked",
        util::prometheus::Labels{},
        "Whether clio detected an amendment block"
    );

    util::prometheus::Bool isCorruptionDetected = PrometheusService::boolMetric(
        "etl_corruption_detected",
        util::prometheus::Labels{},
        "Whether clio detected a corruption that needs manual attention"
    );

    util::prometheus::Bool isWriterDecidingFallback = PrometheusService::boolMetric(
        "etl_writing_deciding_fallback",
        util::prometheus::Labels{},
        "Whether the cluster is using the fallback writer decision mechanism"
    );
};
 
}  // namespace etl