system_monitor.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <chrono>
#include <cstddef>
#include <functional>
#include <memory>
#include <optional>
#include <string>
#include <vector>
 
namespace pulsatrix {
 
namespace detail {
class PlatformSources;
}  // namespace detail
 
struct GpuSample {
    int index = 0;       
    std::string name;    
    std::string vendor;  
    std::optional<double> utilization_percent;  
    std::optional<double> memory_used_bytes;    
    std::optional<double> memory_total_bytes;   
    std::optional<double> memory_gtt_used_bytes;
    std::optional<double> temperature_c;  
    std::optional<double> power_watts;    
};
 
struct SystemSample {
    std::chrono::system_clock::time_point timestamp;  
    double elapsed_seconds = 0.0;  
    std::optional<double> cpu_utilization_percent;  
    std::optional<double> process_cpu_percent;
    std::optional<double> memory_used_bytes;   
    std::optional<double> memory_total_bytes;  
    std::optional<double> process_rss_bytes;   
    std::optional<double> cpu_temperature_c;   
    std::vector<GpuSample> gpus;               
    std::string label;                         
};
 
struct MetricCapability {
    std::string metric;  
    bool available = false;
    std::string detail;  
};
 
enum class LogFormat {
    JsonLines,  
    Csv         
};
 
class SystemMonitor {
public:
    struct Options {
        std::chrono::milliseconds interval{1000};  
        std::string log_path = "";                 
        LogFormat format = LogFormat::JsonLines;   
        bool append = false;
        std::size_t history_capacity = 3600;  
    };
 
    SystemMonitor();
 
    explicit SystemMonitor(Options options);
 
    SystemMonitor(Options options, std::unique_ptr<detail::PlatformSources> sources);
 
    ~SystemMonitor();
 
    SystemMonitor(const SystemMonitor&) = delete;
    SystemMonitor& operator=(const SystemMonitor&) = delete;
 
    void start();
 
    void stop();
 
    [[nodiscard]] bool running() const;
 
    [[nodiscard]] SystemSample sample_now();
 
    [[nodiscard]] std::optional<SystemSample> latest() const;
 
    [[nodiscard]] std::vector<SystemSample> history() const;
 
    void on_sample(std::function<void(const SystemSample&)> callback);
 
    void mark(std::string label);
 
    [[nodiscard]] std::vector<MetricCapability> capabilities() const;
 
    [[nodiscard]] const Options& options() const noexcept;
 
private:
    struct Impl;
    std::unique_ptr<Impl> impl_;
};
 
std::string format_iso8601_utc(std::chrono::system_clock::time_point tp);
 
std::string sample_to_json(const SystemSample& sample);
 
}  // namespace pulsatrix