database::monitoring::prometheus_exporter Class Reference

Export metrics in Prometheus format. More...

#include <performance_monitor.h>

Inheritance diagram for database::monitoring::prometheus_exporter:

Collaboration diagram for database::monitoring::prometheus_exporter:

Public Member Functions
	prometheus_exporter (const std::string &endpoint, int port)
bool	export_metrics (const performance_summary &summary) override
bool	export_alerts (const std::vector< performance_alert > &alerts) override
std::string	format_prometheus_metrics (const performance_summary &summary) const
Public Member Functions inherited from database::monitoring::metrics_exporter
virtual	~metrics_exporter ()=default

Private Attributes
std::string	endpoint_
int	port_

Detailed Description

Export metrics in Prometheus format.

Definition at line 294 of file performance_monitor.h.

Constructor & Destructor Documentation

prometheus_exporter()

database::monitoring::prometheus_exporter::prometheus_exporter	(	const std::string &	endpoint,
		int	port )

Definition at line 495 of file performance_monitor.cpp.

        : endpoint_(endpoint), port_(port)
    {
    }

Member Function Documentation

export_alerts()

bool database::monitoring::prometheus_exporter::export_alerts ( const std::vector< performance_alert > & alerts )

overridevirtual

Implements database::monitoring::metrics_exporter.

Definition at line 508 of file performance_monitor.cpp.

    {
        // Export alerts as metrics
        for (const auto& alert : alerts) {
            std::cout << "database_alert{type=\"" << static_cast<int>(alert.type())
                      << "\"} 1 " << std::chrono::duration_cast<std::chrono::milliseconds>(
                          alert.timestamp().time_since_epoch()).count() << std::endl;
        }
        return true;
    }

Referenced by TEST_F().

Here is the caller graph for this function:

export_metrics()

bool database::monitoring::prometheus_exporter::export_metrics ( const performance_summary & summary )

overridevirtual

Implements database::monitoring::metrics_exporter.

Definition at line 500 of file performance_monitor.cpp.

    {
        // In a real implementation, this would send HTTP POST to Prometheus push gateway
        std::string metrics = format_prometheus_metrics(summary);
        std::cout << "Prometheus metrics:\n" << metrics << std::endl;
        return true;
    }

References format_prometheus_metrics().

Referenced by TEST_F().

Here is the call graph for this function:

Here is the caller graph for this function:

format_prometheus_metrics()

std::string database::monitoring::prometheus_exporter::format_prometheus_metrics

(

const performance_summary &

summary

)

const

Definition at line 519 of file performance_monitor.cpp.

    {
        std::ostringstream metrics;
 
        metrics << "# HELP database_queries_total Total number of database queries\n";
        metrics << "# TYPE database_queries_total counter\n";
        metrics << "database_queries_total " << summary.total_queries << "\n";
 
        metrics << "# HELP database_query_duration_microseconds Average query duration in microseconds\n";
        metrics << "# TYPE database_query_duration_microseconds gauge\n";
        metrics << "database_query_duration_microseconds " << summary.avg_query_time.count() << "\n";
 
        metrics << "# HELP database_error_rate Query error rate\n";
        metrics << "# TYPE database_error_rate gauge\n";
        metrics << "database_error_rate " << summary.error_rate << "\n";
 
        metrics << "# HELP database_connections_active Active database connections\n";
        metrics << "# TYPE database_connections_active gauge\n";
        metrics << "database_connections_active " << summary.active_connections << "\n";
 
        return metrics.str();
    }

References database::monitoring::performance_summary::active_connections, database::monitoring::performance_summary::avg_query_time, database::monitoring::performance_summary::error_rate, and database::monitoring::performance_summary::total_queries.

Referenced by export_metrics(), and TEST_F().

Here is the caller graph for this function:

Member Data Documentation

endpoint_

std::string database::monitoring::prometheus_exporter::endpoint_

private

Definition at line 305 of file performance_monitor.h.

port_

int database::monitoring::prometheus_exporter::port_

private

Definition at line 306 of file performance_monitor.h.

---

The documentation for this class was generated from the following files:

• database/monitoring/performance_monitor.h
• database/monitoring/performance_monitor.cpp