Manages lifecycle and coordination of all database system adapters. More...

#include <database_coordinator.h>

Collaboration diagram for database::integrated::database_coordinator:

Classes
struct	coordinator_stats
	Get coordinator statistics. More...

class	impl

Public Member Functions
	database_coordinator (const unified_db_config &config)
	Construct coordinator with configuration.

	~database_coordinator ()
	Destructor - ensures graceful shutdown.

	database_coordinator (const database_coordinator &)=delete

database_coordinator &	operator= (const database_coordinator &)=delete

	database_coordinator (database_coordinator &&) noexcept

database_coordinator &	operator= (database_coordinator &&) noexcept

common::VoidResult	initialize ()
	Initialize all adapters in correct order.

common::VoidResult	shutdown ()
	Shutdown all adapters in reverse order.

bool	is_initialized () const
	Check if coordinator is initialized.

adapters::logger_adapter *	get_logger ()
	Get logger adapter.

adapters::monitoring_adapter *	get_monitor ()
	Get monitoring adapter.

adapters::thread_adapter *	get_thread_pool ()
	Get thread adapter.

common::Result< bool >	check_health ()
	Perform aggregate health check of all adapters.

common::Result< coordinator_stats >	get_stats () const

Private Attributes
std::unique_ptr< impl >	pimpl_

Detailed Description

Manages lifecycle and coordination of all database system adapters.

This class is responsible for:

Creating all adapter instances
Initializing them in the correct order
Providing access to initialized adapters
Shutting down in reverse order
Aggregating health checks

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

Definition at line 98 of file database_coordinator.h.

Constructor & Destructor Documentation

◆ database_coordinator() [1/3]

database::integrated::database_coordinator::database_coordinator ( const unified_db_config & config )

explicit

Construct coordinator with configuration.

Parameters

config Unified configuration for all adapters

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

Definition at line 386 of file database_coordinator.cpp.

    : pimpl_(std::make_unique<impl>(config))
{
}

◆ ~database_coordinator()

database::integrated::database_coordinator::~database_coordinator ( )

default

Destructor - ensures graceful shutdown.

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

◆ database_coordinator() [2/3]

database::integrated::database_coordinator::database_coordinator ( const database_coordinator & )

delete

◆ database_coordinator() [3/3]

database::integrated::database_coordinator::database_coordinator ( database_coordinator && )

defaultnoexcept

Member Function Documentation

◆ check_health()

common::Result< bool > database::integrated::database_coordinator::check_health ( )

Perform aggregate health check of all adapters.

Checks:

Logger is functional
Monitoring is collecting metrics
Thread pool is accepting tasks

Returns: true if all adapters are healthy

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

Definition at line 426 of file database_coordinator.cpp.

{
    return pimpl_->check_health();
}

References pimpl_.

Referenced by test_full_integration(), and test_health_check().

Here is the caller graph for this function:

◆ get_logger()

adapters::logger_adapter * database::integrated::database_coordinator::get_logger ( )

Get logger adapter.

Returns: Pointer to logger adapter (nullptr if not initialized)

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

Definition at line 411 of file database_coordinator.cpp.

{
    return pimpl_->get_logger();
}

References pimpl_.

Referenced by test_adapter_access(), test_full_integration(), and test_logger_functionality().

Here is the caller graph for this function:

◆ get_monitor()

adapters::monitoring_adapter * database::integrated::database_coordinator::get_monitor ( )

Get monitoring adapter.

Returns: Pointer to monitoring adapter (nullptr if not initialized)

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

Definition at line 416 of file database_coordinator.cpp.

{
    return pimpl_->get_monitor();
}

References pimpl_.

Referenced by test_adapter_access(), test_full_integration(), and test_monitoring_functionality().

Here is the caller graph for this function:

◆ get_stats()

common::Result< database_coordinator::coordinator_stats > database::integrated::database_coordinator::get_stats ( ) const

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

Definition at line 431 of file database_coordinator.cpp.

{
    return pimpl_->get_stats();
}

References pimpl_.

Referenced by test_statistics().

Here is the caller graph for this function:

◆ get_thread_pool()

adapters::thread_adapter * database::integrated::database_coordinator::get_thread_pool ( )

Get thread adapter.

Returns: Pointer to thread adapter (nullptr if not initialized)

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

Definition at line 421 of file database_coordinator.cpp.

{
    return pimpl_->get_thread_pool();
}

References pimpl_.

Referenced by test_adapter_access(), test_full_integration(), and test_thread_pool_functionality().

Here is the caller graph for this function:

◆ initialize()

common::VoidResult database::integrated::database_coordinator::initialize ( )

Initialize all adapters in correct order.

Initialization order:

Logger adapter (for observability)
Monitoring adapter (for metrics)
Thread adapter (for async operations)

If any initialization fails, previously initialized adapters are shut down cleanly.

Returns: Success or error with details

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

Definition at line 396 of file database_coordinator.cpp.

{
    return pimpl_->initialize();
}

References initialize().

Referenced by initialize(), test_adapter_access(), test_automatic_shutdown_in_destructor(), test_basic_initialization_and_shutdown(), test_double_initialization(), test_full_integration(), test_health_check(), test_logger_functionality(), test_monitoring_functionality(), test_statistics(), and test_thread_pool_functionality().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ is_initialized()

bool database::integrated::database_coordinator::is_initialized ( ) const

Check if coordinator is initialized.

Returns: true if initialized, false otherwise

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

Definition at line 406 of file database_coordinator.cpp.

{
    return pimpl_->is_initialized();
}

References pimpl_.

Referenced by test_basic_initialization_and_shutdown().

Here is the caller graph for this function:

◆ operator=() [1/2]

database_coordinator & database::integrated::database_coordinator::operator= ( const database_coordinator & )

delete

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

◆ operator=() [2/2]

database_coordinator & database::integrated::database_coordinator::operator= ( database_coordinator && )

defaultnoexcept

◆ shutdown()

common::VoidResult database::integrated::database_coordinator::shutdown ( )

Shutdown all adapters in reverse order.

Shutdown order (reverse of init):

Thread adapter
Monitoring adapter
Logger adapter (last, for final logging)

Returns: Success or error with details

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

Definition at line 401 of file database_coordinator.cpp.

{
    return pimpl_->shutdown();
}

References pimpl_.

Referenced by test_adapter_access(), test_basic_initialization_and_shutdown(), test_double_initialization(), test_full_integration(), test_health_check(), test_logger_functionality(), test_monitoring_functionality(), test_shutdown_without_initialization(), test_statistics(), and test_thread_pool_functionality().

Here is the caller graph for this function:

Member Data Documentation

◆ pimpl_

std::unique_ptr<impl> database::integrated::database_coordinator::pimpl_

private

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

Definition at line 205 of file database_coordinator.h.

Referenced by check_health(), get_logger(), get_monitor(), get_stats(), get_thread_pool(), is_initialized(), and shutdown().

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

database/integrated/core/database_coordinator.h
database/integrated/core/database_coordinator.cpp

Classes

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ database_coordinator() [1/3]

◆ ~database_coordinator()

◆ database_coordinator() [2/3]

◆ database_coordinator() [3/3]

Member Function Documentation

◆ check_health()

◆ get_logger()

◆ get_monitor()

◆ get_stats()

◆ get_thread_pool()

◆ initialize()

◆ is_initialized()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ shutdown()

Member Data Documentation

◆ pimpl_