database::integrated::adapters::monitoring_adapter Class Reference

Monitoring adapter for database operations. More...

#include <monitoring_adapter.h>

Collaboration diagram for database::integrated::adapters::monitoring_adapter:

Public Member Functions
	monitoring_adapter (const db_monitoring_config &config, monitoring_backend_type backend_type=monitoring_backend_type::auto_select)
	Construct monitoring adapter with configuration.
	~monitoring_adapter ()
	Destructor - ensures graceful shutdown.
	monitoring_adapter (const monitoring_adapter &)=delete
monitoring_adapter &	operator= (const monitoring_adapter &)=delete
	monitoring_adapter (monitoring_adapter &&) noexcept
monitoring_adapter &	operator= (monitoring_adapter &&)=delete
common::VoidResult	initialize ()
	Initialize monitoring system.
common::VoidResult	shutdown ()
	Shutdown monitoring system.
bool	is_initialized () const
	Check if monitoring is initialized.
common::VoidResult	record_metric (const std::string &name, double value)
	Record a metric value.
common::VoidResult	record_metric (const std::string &name, double value, const std::unordered_map< std::string, std::string > &tags)
	Record a metric value with tags.
common::Result< backends::metrics_snapshot >	get_metrics ()
	Get current metrics snapshot.
common::Result< backends::health_check_result >	check_health ()
	Perform health check.
common::VoidResult	reset ()
	Reset all metrics.
void	record_query_execution (std::chrono::microseconds duration, bool success)
	Record query execution.
void	record_connection_acquired ()
	Record connection acquisition.
void	record_connection_released ()
	Record connection release.
void	update_pool_stats (std::size_t active, std::size_t idle, std::size_t total)
	Update connection pool statistics.
void	record_transaction_begin ()
	Record transaction begin.
void	record_transaction_commit ()
	Record transaction commit.
void	record_transaction_rollback ()
	Record transaction rollback.
common::Result< database_metrics >	get_database_metrics ()
	Get database-specific metrics.
std::string	export_prometheus_metrics ()
	Export metrics in Prometheus format.

Static Private Member Functions
static std::unique_ptr< backends::monitoring_backend >	create_backend (const db_monitoring_config &config, monitoring_backend_type backend_type)
	Create appropriate backend based on type.

Private Attributes
const db_monitoring_config &	config_
std::unique_ptr< backends::monitoring_backend >	backend_
	Monitoring backend implementation.

Detailed Description

Monitoring adapter for database operations.

Provides comprehensive monitoring capabilities with runtime backend selection. No longer uses conditional compilation - backend is selected at runtime.

Features:

• Connection pool monitoring
• Query performance tracking with percentiles
• Transaction lifecycle tracking
• Health checks with configurable thresholds
• Prometheus metrics export

Thread Safety: Thread-safe with internal synchronization

Examples

/home/runner/work/database_system/database_system/database/integrated/core/database_coordinator.h.

Definition at line 156 of file monitoring_adapter.h.

Constructor & Destructor Documentation

monitoring_adapter() [1/3]

database::integrated::adapters::monitoring_adapter::monitoring_adapter ( const db_monitoring_config & config, monitoring_backend_type backend_type = monitoring_backend_type::auto_select )

explicit

Construct monitoring adapter with configuration.

Parameters

config	Monitoring configuration
backend_type	Backend type to use (default: auto_select)

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 63 of file monitoring_adapter.cpp.

    : config_(config)
    , backend_(create_backend(config, backend_type))
{
}

~monitoring_adapter()

database::integrated::adapters::monitoring_adapter::~monitoring_adapter

(

)

Destructor - ensures graceful shutdown.

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 71 of file monitoring_adapter.cpp.

{
    if (backend_ && backend_->is_initialized())
    {
        backend_->shutdown();
    }
}

References backend_.

monitoring_adapter() [2/3]

database::integrated::adapters::monitoring_adapter::monitoring_adapter ( const monitoring_adapter & )

delete

monitoring_adapter() [3/3]

database::integrated::adapters::monitoring_adapter::monitoring_adapter ( monitoring_adapter && )

defaultnoexcept

Member Function Documentation

check_health()

common::Result< backends::health_check_result > database::integrated::adapters::monitoring_adapter::check_health

(

)

Perform health check.

Returns

Health check result

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 146 of file monitoring_adapter.cpp.

{
    if (!backend_)
    {
        return common::Result<backends::health_check_result>(
            common::error_info{ -1, "Backend not initialized", "" });
    }
 
    return backend_->check_health();
}

References backend_.

Referenced by test_api_availability_health().

Here is the caller graph for this function:

create_backend()

std::unique_ptr< backends::monitoring_backend > database::integrated::adapters::monitoring_adapter::create_backend ( const db_monitoring_config & config, monitoring_backend_type backend_type )

staticprivate

Create appropriate backend based on type.

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 26 of file monitoring_adapter.cpp.

{
    switch (backend_type)
    {
        case monitoring_backend_type::auto_select:
            // Prefer system_monitoring_backend if available
#ifdef HAVE_SYSTEM_MONITORING_BACKEND
            return std::make_unique<backends::system_monitoring_backend>(config);
#else
            return std::make_unique<backends::fallback_monitoring_backend>(config);
#endif
 
        case monitoring_backend_type::system:
#ifdef HAVE_SYSTEM_MONITORING_BACKEND
            return std::make_unique<backends::system_monitoring_backend>(config);
#else
            // Fallback to fallback backend if system backend not available
            return std::make_unique<backends::fallback_monitoring_backend>(config);
#endif
 
        case monitoring_backend_type::fallback:
            return std::make_unique<backends::fallback_monitoring_backend>(config);
 
        case monitoring_backend_type::null:
            return std::make_unique<backends::null_monitoring_backend>(config);
 
        default:
            return std::make_unique<backends::fallback_monitoring_backend>(config);
    }
}

References database::integrated::adapters::auto_select, database::integrated::adapters::fallback, database::integrated::adapters::null, and database::integrated::adapters::system.

export_prometheus_metrics()

std::string database::integrated::adapters::monitoring_adapter::export_prometheus_metrics

(

)

Export metrics in Prometheus format.

Returns

Prometheus-formatted metrics string

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 239 of file monitoring_adapter.cpp.

{
    if (!backend_)
    {
        return "# Backend not initialized\n";
    }
 
    return backend_->export_prometheus_metrics();
}

References backend_.

Referenced by test_api_availability_prometheus().

Here is the caller graph for this function:

get_database_metrics()

common::Result< database_metrics > database::integrated::adapters::monitoring_adapter::get_database_metrics

(

)

Get database-specific metrics.

Returns

Database metrics on success

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 228 of file monitoring_adapter.cpp.

{
    if (!backend_)
    {
        return common::Result<database_metrics>(
            common::error_info{ -1, "Backend not initialized", "" });
    }
 
    return backend_->get_database_metrics();
}

References backend_.

Referenced by test_api_availability_metrics().

Here is the caller graph for this function:

get_metrics()

common::Result< backends::metrics_snapshot > database::integrated::adapters::monitoring_adapter::get_metrics

(

)

Get current metrics snapshot.

Returns

Metrics snapshot on success

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 135 of file monitoring_adapter.cpp.

{
    if (!backend_)
    {
        return common::Result<backends::metrics_snapshot>(
            common::error_info{ -1, "Backend not initialized", "" });
    }
 
    return backend_->get_metrics();
}

References backend_.

Referenced by test_api_availability_metrics().

Here is the caller graph for this function:

initialize()

common::VoidResult database::integrated::adapters::monitoring_adapter::initialize

(

)

Initialize monitoring system.

Returns

Ok on success, error otherwise

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 81 of file monitoring_adapter.cpp.

{
    if (!backend_)
    {
        return common::VoidResult(
            common::error_info{ -1, "Backend not created", "" });
    }
 
    return backend_->initialize();
}

References initialize().

Referenced by initialize().

Here is the call graph for this function:

Here is the caller graph for this function:

is_initialized()

bool database::integrated::adapters::monitoring_adapter::is_initialized

(

)

const

Check if monitoring is initialized.

Returns

true if initialized

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 102 of file monitoring_adapter.cpp.

{
    return backend_ && backend_->is_initialized();
}

References backend_.

operator=() [1/2]

monitoring_adapter & database::integrated::adapters::monitoring_adapter::operator= ( const monitoring_adapter & )

delete

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

operator=() [2/2]

monitoring_adapter & database::integrated::adapters::monitoring_adapter::operator= ( monitoring_adapter && )

delete

record_connection_acquired()

void database::integrated::adapters::monitoring_adapter::record_connection_acquired

(

)

Record connection acquisition.

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 180 of file monitoring_adapter.cpp.

{
    if (backend_)
    {
        backend_->record_connection_acquired();
    }
}

References backend_.

Referenced by test_api_availability_basic(), test_destructor_safety(), test_move_semantics(), and test_multiple_instances().

Here is the caller graph for this function:

record_connection_released()

void database::integrated::adapters::monitoring_adapter::record_connection_released

(

)

Record connection release.

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 188 of file monitoring_adapter.cpp.

{
    if (backend_)
    {
        backend_->record_connection_released();
    }
}

References backend_.

Referenced by test_api_availability_basic().

Here is the caller graph for this function:

record_metric() [1/2]

common::VoidResult database::integrated::adapters::monitoring_adapter::record_metric	(	const std::string &	name,
		double	value )

Record a metric value.

Parameters

name	Metric name
value	Metric value

Returns

Ok on success

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 111 of file monitoring_adapter.cpp.

{
    if (!backend_)
    {
        return common::VoidResult(
            common::error_info{ -1, "Backend not initialized", "" });
    }
 
    return backend_->record_metric(name, value);
}

References backend_.

record_metric() [2/2]

common::VoidResult database::integrated::adapters::monitoring_adapter::record_metric	(	const std::string &	name,
		double	value,
		const std::unordered_map< std::string, std::string > &	tags )

Record a metric value with tags.

Parameters

name	Metric name
value	Metric value
tags	Metric tags/labels

Returns

Ok on success

Definition at line 122 of file monitoring_adapter.cpp.

{
    if (!backend_)
    {
        return common::VoidResult(
            common::error_info{ -1, "Backend not initialized", "" });
    }
 
    return backend_->record_metric(name, value, tags);
}

References backend_.

record_query_execution()

void database::integrated::adapters::monitoring_adapter::record_query_execution	(	std::chrono::microseconds	duration,
		bool	success )

Record query execution.

Parameters

duration	Query execution duration
success	Whether query succeeded

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 172 of file monitoring_adapter.cpp.

{
    if (backend_)
    {
        backend_->record_query_execution(duration, success);
    }
}

References backend_, and database::success.

Referenced by test_api_availability_basic().

Here is the caller graph for this function:

record_transaction_begin()

void database::integrated::adapters::monitoring_adapter::record_transaction_begin

(

)

Record transaction begin.

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 204 of file monitoring_adapter.cpp.

{
    if (backend_)
    {
        backend_->record_transaction_begin();
    }
}

References backend_.

Referenced by test_api_availability_basic().

Here is the caller graph for this function:

record_transaction_commit()

void database::integrated::adapters::monitoring_adapter::record_transaction_commit

(

)

Record transaction commit.

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 212 of file monitoring_adapter.cpp.

{
    if (backend_)
    {
        backend_->record_transaction_commit();
    }
}

References backend_.

Referenced by test_api_availability_basic().

Here is the caller graph for this function:

record_transaction_rollback()

void database::integrated::adapters::monitoring_adapter::record_transaction_rollback

(

)

Record transaction rollback.

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 220 of file monitoring_adapter.cpp.

{
    if (backend_)
    {
        backend_->record_transaction_rollback();
    }
}

References backend_.

Referenced by test_api_availability_basic().

Here is the caller graph for this function:

reset()

common::VoidResult database::integrated::adapters::monitoring_adapter::reset

(

)

Reset all metrics.

Returns

Ok on success

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 157 of file monitoring_adapter.cpp.

{
    if (!backend_)
    {
        return common::VoidResult(
            common::error_info{ -1, "Backend not initialized", "" });
    }
 
    return backend_->reset();
}

References backend_.

Referenced by test_api_availability_reset().

Here is the caller graph for this function:

shutdown()

common::VoidResult database::integrated::adapters::monitoring_adapter::shutdown

(

)

Shutdown monitoring system.

Returns

Ok on success, error otherwise

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 92 of file monitoring_adapter.cpp.

{
    if (!backend_)
    {
        return common::ok();
    }
 
    return backend_->shutdown();
}

References backend_, and common::ok().

Here is the call graph for this function:

update_pool_stats()

void database::integrated::adapters::monitoring_adapter::update_pool_stats	(	std::size_t	active,
		std::size_t	idle,
		std::size_t	total )

Update connection pool statistics.

Parameters

active	Number of active connections
idle	Number of idle connections
total	Total pool size

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 196 of file monitoring_adapter.cpp.

{
    if (backend_)
    {
        backend_->update_pool_stats(active, idle, total);
    }
}

References backend_.

Referenced by test_api_availability_basic().

Here is the caller graph for this function:

Member Data Documentation

backend_

std::unique_ptr<backends::monitoring_backend> database::integrated::adapters::monitoring_adapter::backend_

private

Monitoring backend implementation.

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 305 of file monitoring_adapter.h.

Referenced by check_health(), export_prometheus_metrics(), get_database_metrics(), get_metrics(), is_initialized(), record_connection_acquired(), record_connection_released(), record_metric(), record_metric(), record_query_execution(), record_transaction_begin(), record_transaction_commit(), record_transaction_rollback(), reset(), shutdown(), update_pool_stats(), and ~monitoring_adapter().

config_

const db_monitoring_config& database::integrated::adapters::monitoring_adapter::config_

private

Examples

/home/runner/work/database_system/database_system/database/integrated/adapters/monitoring_adapter.h.

Definition at line 304 of file monitoring_adapter.h.

---

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

• database/integrated/adapters/monitoring_adapter.h
• database/integrated/adapters/monitoring_adapter.cpp