Class cubconn::connection::coordinator¶

ClassList > cubconn > connection > coordinator

#include <coordinator.hpp>

Classes¶

Type	Name
struct	message

Public Types¶

Type	Name
enum	message_type

Public Attributes¶

Type	Name
std::pair< double, uint64_t >	completed
std::size_t	count
std::pair< double, uint64_t >	depth
scaling_direction	direction
int	draining_worker
std::vector< scaling_statistics >	history
uint64_t	last_drain_ns
uint64_t	last_expand_ns
scaling_direction	previous_direction
std::size_t	previous_scale
std::pair< double, uint64_t >	requested
std::pair< double, uint64_t >	started
scaling_status	status
uint64_t	time_ns
std::size_t	window_size
std::uint32_t	workers

Public Functions¶

Type	Name
void	attach ()
	coordinator (pool * pool, std::shared_ptr< thread_watcher > watcher, std::size_t core, std::uint32_t max_worker, std::uint32_t min_worker)
void	enqueue (message && item)
void	finalize ()
void	initialize ()
bool	notify ()
bool	run ()
	~coordinator ()

Public Types Documentation¶

enum message_type¶

enum cubconn::connection::coordinator::message_type {
    START,
    NEW_CLIENT,
    RETURN_TO_POOL,
    HANDOFF_REPLY,
    STATISTICS,
    SHUTDOWN,
    TYPE_COUNT
};

Public Attributes Documentation¶

variable completed¶

std::pair<double, uint64_t> cubconn::connection::coordinator::completed;

variable count¶

std::size_t cubconn::connection::coordinator::count;

variable depth¶

std::pair<double, uint64_t> cubconn::connection::coordinator::depth;

variable direction¶

scaling_direction cubconn::connection::coordinator::direction;

variable draining_worker¶

int cubconn::connection::coordinator::draining_worker;

variable history¶

std::vector<scaling_statistics> cubconn::connection::coordinator::history;

variable last_drain_ns¶

uint64_t cubconn::connection::coordinator::last_drain_ns;

variable last_expand_ns¶

uint64_t cubconn::connection::coordinator::last_expand_ns;

variable previous_direction¶

scaling_direction cubconn::connection::coordinator::previous_direction;

variable previous_scale¶

std::size_t cubconn::connection::coordinator::previous_scale;

variable requested¶

std::pair<double, uint64_t> cubconn::connection::coordinator::requested;

variable started¶

std::pair<double, uint64_t> cubconn::connection::coordinator::started;

variable status [2/2]¶

scaling_status cubconn::connection::coordinator::status;

variable time_ns¶

uint64_t cubconn::connection::coordinator::time_ns;

variable window_size¶

std::size_t cubconn::connection::coordinator::window_size;

variable workers¶

std::uint32_t cubconn::connection::coordinator::workers;

Public Functions Documentation¶

function attach¶

void cubconn::connection::coordinator::attach ()

function coordinator¶

cubconn::connection::coordinator::coordinator (
    pool * pool,
    std::shared_ptr< thread_watcher > watcher,
    std::size_t core,
    std::uint32_t max_worker,
    std::uint32_t min_worker
)

function enqueue¶

void cubconn::connection::coordinator::enqueue (
    message && item
)

function finalize¶

void cubconn::connection::coordinator::finalize ()

function initialize¶

void cubconn::connection::coordinator::initialize ()

function notify¶

bool cubconn::connection::coordinator::notify ()

function run¶

bool cubconn::connection::coordinator::run ()

function ~coordinator¶

cubconn::connection::coordinator::~coordinator ()

The documentation for this class was generated from the following file cubrid/src/connection/coordinator.hpp