network_metrics.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2024-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include <cstddef>
#include <map>
#include <string>
 
namespace kcenon::network::metrics {
 
// Forward declarations
struct histogram_snapshot;
class histogram;
 
namespace metric_names {
    // Connection metrics
    constexpr const char* CONNECTIONS_ACTIVE = "network.connections.active";
    constexpr const char* CONNECTIONS_TOTAL = "network.connections.total";
    constexpr const char* CONNECTIONS_FAILED = "network.connections.failed";
 
    // Transfer metrics
    constexpr const char* BYTES_SENT = "network.bytes.sent";
    constexpr const char* BYTES_RECEIVED = "network.bytes.received";
    constexpr const char* PACKETS_SENT = "network.packets.sent";
    constexpr const char* PACKETS_RECEIVED = "network.packets.received";
 
    // Performance metrics
    constexpr const char* LATENCY_MS = "network.latency.ms";
    constexpr const char* THROUGHPUT_MBPS = "network.throughput.mbps";
    constexpr const char* SESSION_DURATION_MS = "network.session.duration.ms";
 
    // Error metrics
    constexpr const char* ERRORS_TOTAL = "network.errors.total";
    constexpr const char* TIMEOUTS_TOTAL = "network.timeouts.total";
 
    // Server metrics
    constexpr const char* SERVER_START_TIME = "network.server.start_time.ms";
    constexpr const char* SERVER_ACCEPT_COUNT = "network.server.accept.count";
    constexpr const char* SERVER_ACCEPT_FAILED = "network.server.accept.failed";
 
    // Histogram metrics
    constexpr const char* LATENCY_HISTOGRAM = "network.latency.histogram";
    constexpr const char* CONNECTION_TIME_HISTOGRAM = "network.connection_time.histogram";
    constexpr const char* REQUEST_DURATION_HISTOGRAM = "network.request_duration.histogram";
}
 
class metric_reporter {
public:
    static void report_connection_accepted();
 
    static void report_connection_failed(const std::string& reason);
 
    static void report_bytes_sent(size_t bytes);
 
    static void report_bytes_received(size_t bytes);
 
    static void report_latency(double ms);
 
    static void report_error(const std::string& error_type);
 
    static void report_timeout();
 
    static void report_active_connections(size_t count);
 
    static void report_session_duration(double ms);
 
    // ========================================================================
    // Histogram-based metrics (with percentile support)
    // ========================================================================
 
    static void record_latency(double ms);
 
    static void record_connection_time(double ms);
 
    static void record_request_duration(double ms);
 
    [[nodiscard]] static auto get_latency_p50() -> double;
 
    [[nodiscard]] static auto get_latency_p95() -> double;
 
    [[nodiscard]] static auto get_latency_p99() -> double;
 
    [[nodiscard]] static auto get_connection_time_p99() -> double;
 
    [[nodiscard]] static auto get_request_duration_p99() -> double;
 
    [[nodiscard]] static auto get_all_histograms()
        -> std::map<std::string, histogram_snapshot>;
 
    static void reset_histograms();
};
 
} // namespace kcenon::network::metrics