monitoring_backend.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include "../../core/common_result.h"
#include "../../core/configuration.h"
 
#include <chrono>
#include <string>
#include <unordered_map>
 
namespace database
{
namespace integrated
{
namespace adapters
{
 
// Forward declare database_metrics from monitoring_adapter.h
struct database_metrics;
 
namespace backends
{
 
struct metrics_snapshot
{
    std::unordered_map<std::string, double> gauges;
    std::unordered_map<std::string, uint64_t> counters;
    std::string source_id;
};
 
enum class health_status
{
    healthy,
    degraded,
    unhealthy,
    unknown
};
 
struct health_check_result
{
    health_status status;
    std::string message;
    std::unordered_map<std::string, std::string> metadata;
};
 
class monitoring_backend
{
public:
    virtual ~monitoring_backend() = default;
 
    virtual common::VoidResult initialize() = 0;
 
    virtual common::VoidResult shutdown() = 0;
 
    virtual bool is_initialized() const = 0;
 
    virtual common::VoidResult record_metric(const std::string& name, double value) = 0;
 
    virtual common::VoidResult record_metric(
        const std::string& name, double value,
        const std::unordered_map<std::string, std::string>& tags) = 0;
 
    virtual common::Result<metrics_snapshot> get_metrics() = 0;
 
    virtual common::Result<health_check_result> check_health() = 0;
 
    virtual common::VoidResult reset() = 0;
 
    virtual void record_query_execution(std::chrono::microseconds duration, bool success) = 0;
 
    virtual void record_connection_acquired() = 0;
 
    virtual void record_connection_released() = 0;
 
    virtual void update_pool_stats(std::size_t active, std::size_t idle, std::size_t total) = 0;
 
    virtual void record_transaction_begin() = 0;
 
    virtual void record_transaction_commit() = 0;
 
    virtual void record_transaction_rollback() = 0;
 
    virtual common::Result<database_metrics> get_database_metrics() = 0;
 
    virtual std::string export_prometheus_metrics() = 0;
};
 
} // namespace backends
} // namespace adapters
} // namespace integrated
} // namespace database