monitoring_adapter.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include <chrono>
#include <cstdint>
#include <functional>
#include <map>
#include <memory>
#include <optional>
#include <string>
#include <string_view>
 
namespace kcenon::pacs::integration {
 
// ─────────────────────────────────────────────────────
// Forward Declarations
// ─────────────────────────────────────────────────────
 
// Note: query_level is defined in logger_adapter.hpp
// If logger_adapter.hpp is not included, we define it here
#ifndef PACS_INTEGRATION_QUERY_LEVEL_DEFINED
#define PACS_INTEGRATION_QUERY_LEVEL_DEFINED
enum class query_level { patient, study, series, image };
#endif
 
// ─────────────────────────────────────────────────────
// Configuration
// ─────────────────────────────────────────────────────
 
struct monitoring_config {
    bool enable_metrics{true};
 
    bool enable_tracing{true};
 
    std::chrono::seconds export_interval{30};
 
    std::optional<std::uint16_t> metrics_port;
 
    std::optional<std::string> tracing_endpoint;
 
    std::string service_name{"pacs_server"};
 
    std::size_t max_samples_per_operation{10000};
};
 
// ─────────────────────────────────────────────────────
// Monitoring Adapter Class
// ─────────────────────────────────────────────────────
 
class monitoring_adapter {
public:
    // ─────────────────────────────────────────────────────
    // Initialization
    // ─────────────────────────────────────────────────────
 
    static void initialize(const monitoring_config& config);
 
    static void shutdown();
 
    [[nodiscard]] static auto is_initialized() noexcept -> bool;
 
    // ─────────────────────────────────────────────────────
    // Metrics
    // ─────────────────────────────────────────────────────
 
    static void increment_counter(std::string_view name, std::int64_t value = 1);
 
    static void set_gauge(std::string_view name, double value);
 
    static void record_histogram(std::string_view name, double value);
 
    static void record_timing(std::string_view name,
                              std::chrono::nanoseconds duration);
 
    // ─────────────────────────────────────────────────────
    // DICOM-Specific Metrics
    // ─────────────────────────────────────────────────────
 
    static void record_c_store(std::chrono::nanoseconds duration,
                               std::size_t bytes,
                               bool success);
 
    static void record_c_find(std::chrono::nanoseconds duration,
                              std::size_t matches,
                              query_level level);
 
    static void record_association(const std::string& calling_ae,
                                   bool established);
 
    static void update_storage_stats(std::size_t total_instances,
                                     std::size_t total_bytes);
 
    // ─────────────────────────────────────────────────────
    // Distributed Tracing
    // ─────────────────────────────────────────────────────
 
    class span {
    public:
        explicit span(std::string_view operation_name);
 
        ~span();
 
        // Disable copy
        span(const span&) = delete;
        span& operator=(const span&) = delete;
 
        // Enable move
        span(span&& other) noexcept;
        span& operator=(span&& other) noexcept;
 
        void set_tag(std::string_view key, std::string_view value);
 
        void add_event(std::string_view name);
 
        void set_error(const std::exception& e);
 
        [[nodiscard]] auto trace_id() const -> std::string;
 
        [[nodiscard]] auto span_id() const -> std::string;
 
        [[nodiscard]] auto is_valid() const noexcept -> bool;
 
    private:
        class impl;
        std::unique_ptr<impl> impl_;
    };
 
    [[nodiscard]] static auto start_span(std::string_view operation) -> span;
 
    // ─────────────────────────────────────────────────────
    // Health Check
    // ─────────────────────────────────────────────────────
 
    struct health_status {
        bool healthy{true};
 
        std::string status{"healthy"};
 
        std::map<std::string, std::string> components;
    };
 
    [[nodiscard]] static auto get_health() -> health_status;
 
    static void register_health_check(std::string_view component,
                                      std::function<bool()> check);
 
    static void unregister_health_check(std::string_view component);
 
    // ─────────────────────────────────────────────────────
    // Configuration
    // ─────────────────────────────────────────────────────
 
    [[nodiscard]] static auto get_config() -> const monitoring_config&;
 
private:
    // Private implementation helpers
    [[nodiscard]] static auto query_level_to_string(query_level level)
        -> std::string;
 
    // Internal state (managed through pimpl or static members)
    class impl;
    static std::unique_ptr<impl> pimpl_;
};
 
}  // namespace kcenon::pacs::integration