Classes
class	async_database
	Asynchronous database interface wrapper. More...

class	async_executor
	High-performance asynchronous executor using thread_system. More...

class	async_result
	Template class for asynchronous operation results. More...

class	fallback_context
	Fallback thread context (empty implementation) Provides a no-op context when thread_system is not available. More...

class	result_type
	Fallback Result<T> implementation. More...

class	result_void_type
	Fallback result_void. More...

class	saga_builder
	Builder for Saga pattern transactions. More...

class	stream_processor
	Real-time data stream processing. More...

class	transaction_coordinator
	Distributed transaction coordination. More...

Typedefs
using	thread_pool_type = fallback_thread_pool
	Fallback thread pool using std::thread Provides basic functionality when thread_system is not available.

template<typename JobType >
using	typed_thread_pool_type = fallback_thread_pool
	Fallback typed thread pool (delegates to regular pool)

using	job_type = fallback_job
	Fallback job type.

template<typename JobType >
using	typed_job_type = fallback_job
	Fallback typed job.

using	thread_context_type = fallback_context
	Fallback thread context (empty)

using	monitoring_interface_type = void
	Fallback monitoring interface (no-op)

using	logger_interface_type = void
	Fallback logger interface (no-op)

Functions
template<typename T >
async_result< T >	make_ready_result (T value)

template<typename T >
async_result< T >	make_error_result (const std::exception &error)

Variables
constexpr bool	using_thread_system = false
	Compile-time flag indicating fallback mode.

Typedef Documentation

◆ job_type

using database::async::job_type = fallback_job

Fallback job type.

Definition at line 149 of file thread_pool_adapter.h.

◆ logger_interface_type

using database::async::logger_interface_type = void

Fallback logger interface (no-op)

Definition at line 170 of file thread_pool_adapter.h.

◆ monitoring_interface_type

using database::async::monitoring_interface_type = void

Fallback monitoring interface (no-op)

Definition at line 165 of file thread_pool_adapter.h.

◆ thread_context_type

using database::async::thread_context_type = fallback_context

Fallback thread context (empty)

Examples: /home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 160 of file thread_pool_adapter.h.

◆ thread_pool_type

using database::async::thread_pool_type = fallback_thread_pool

Fallback thread pool using std::thread Provides basic functionality when thread_system is not available.

Definition at line 138 of file thread_pool_adapter.h.

◆ typed_job_type

template<typename JobType >

using database::async::typed_job_type = fallback_job

Fallback typed job.

Definition at line 155 of file thread_pool_adapter.h.

◆ typed_thread_pool_type

template<typename JobType >

using database::async::typed_thread_pool_type = fallback_thread_pool

Fallback typed thread pool (delegates to regular pool)

Definition at line 144 of file thread_pool_adapter.h.

Function Documentation

◆ make_error_result()

template<typename T >

async_result< T > database::async::make_error_result ( const std::exception & error )

Examples: /home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 884 of file async_operations.h.

                                                                 {
        std::promise<T> promise;
        promise.set_exception(std::make_exception_ptr(error));
        return async_result<T>(promise.get_future());
    }

Referenced by database::async::transaction_coordinator::commit_phase(), database::async::transaction_coordinator::prepare_phase(), database::async::transaction_coordinator::rollback_distributed_transaction(), TEST(), and TEST().

Here is the caller graph for this function:

◆ make_ready_result()

template<typename T >

async_result< T > database::async::make_ready_result ( T value )

Examples: /home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 877 of file async_operations.h.

                                               {
        std::promise<T> promise;
        promise.set_value(std::move(value));
        return async_result<T>(promise.get_future());
    }

Referenced by database::async::transaction_coordinator::commit_phase(), database::async::saga_builder::execute(), database::async::transaction_coordinator::prepare_phase(), database::async::transaction_coordinator::rollback_distributed_transaction(), TEST(), TEST(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), TEST_F(), and database::async::transaction_coordinator::two_phase_commit().

Here is the caller graph for this function:

Variable Documentation

◆ using_thread_system

bool database::async::using_thread_system = false

constexpr

Compile-time flag indicating fallback mode.

Examples: /home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 216 of file thread_pool_adapter.h.

Referenced by database::async::async_executor::is_using_thread_system().

Classes

Typedefs

Functions

Variables