#include <connection.h>

Inheritance diagram for MySQLRoutingConnectionBase:

Classes
struct	Stats

Public Types
using	clock_type = std::chrono::system_clock

using	time_point_type = clock_type::time_point

Public Member Functions
	MySQLRoutingConnectionBase (MySQLRoutingContext &context, std::function< void(MySQLRoutingConnectionBase *)> remove_callback)

virtual	~MySQLRoutingConnectionBase ()=default

MySQLRoutingContext &	context ()

const MySQLRoutingContext &	context () const

virtual std::optional< mysql_harness::Destination >	get_destination_id () const =0

virtual std::optional< mysql_harness::Destination >	read_only_destination_id () const

virtual std::optional< mysql_harness::Destination >	read_write_destination_id () const

virtual std::optional< mysql_harness::DestinationEndpoint >	destination_endpoint () const =0

virtual std::optional< mysql_harness::DestinationEndpoint >	read_only_destination_endpoint () const

virtual std::optional< mysql_harness::DestinationEndpoint >	read_write_destination_endpoint () const

virtual net::impl::socket::native_handle_type	get_client_fd () const =0

virtual std::string	get_routing_source () const =0

virtual void	set_routing_source (std::string name)=0

virtual void	wait_until_completed ()=0

virtual void	completed ()=0

virtual routing_guidelines::Server_info	get_server_info () const =0

std::string	get_server_address () const
	Returns address of server to which connection is established. More...

void	server_address (const std::string &dest)

virtual void	disconnect ()=0

std::string	get_client_address () const
	Returns address of client which connected to router. More...

void	client_address (const std::string &dest)

std::size_t	get_bytes_up () const

std::size_t	get_bytes_down () const

time_point_type	get_started () const

time_point_type	get_connected_to_server () const

time_point_type	get_last_sent_to_server () const

time_point_type	get_last_received_from_server () const

Stats	get_stats () const

void	transfered_to_server (size_t bytes)

void	transfered_to_client (size_t bytes)

void	disassociate ()

void	accepted ()

virtual void	connected ()

template<class F >
auto	disconnect_request (F &&f)

bool	disconnect_requested () const

routing_guidelines::Session_info	get_session_info () const

void	set_routing_guidelines_session_rand ()

Protected Member Functions
void	log_connection_summary ()

Protected Attributes
MySQLRoutingContext &	context_
	wrapper for common data used by all routing threads More...

std::function< void(MySQLRoutingConnectionBase *)>	remove_callback_
	callback that is called when thread of execution completes More...

Monitor< Stats >	stats_ {{}}

Monitor< bool >	disconnect_ {{}}

Private Attributes
net::impl::socket::native_handle_type	client_fd_

std::optional< double >	routing_guidelines_session_rand_

Member Typedef Documentation

◆ clock_type

using MySQLRoutingConnectionBase::clock_type = std::chrono::system_clock

◆ time_point_type

using MySQLRoutingConnectionBase::time_point_type = clock_type::time_point

Constructor & Destructor Documentation

◆ MySQLRoutingConnectionBase()

MySQLRoutingConnectionBase::MySQLRoutingConnectionBase	(	MySQLRoutingContext &	context,
		std::function< void(MySQLRoutingConnectionBase *)>	remove_callback
	)

inline

◆ ~MySQLRoutingConnectionBase()

virtual MySQLRoutingConnectionBase::~MySQLRoutingConnectionBase ( )

virtualdefault

Member Function Documentation

◆ accepted()

void MySQLRoutingConnectionBase::accepted ( )

◆ client_address()

void MySQLRoutingConnectionBase::client_address ( const std::string & dest )

inline

◆ completed()

virtual void MySQLRoutingConnectionBase::completed ( )

pure virtual

Implemented in MysqlRoutingClassicConnectionBase, and MysqlRoutingXConnection.

◆ connected()

void MySQLRoutingConnectionBase::connected ( )

virtual

◆ context() [1/2]

MySQLRoutingContext & MySQLRoutingConnectionBase::context ( )

inline

◆ context() [2/2]

const MySQLRoutingContext & MySQLRoutingConnectionBase::context ( ) const

inline

◆ destination_endpoint()

virtual std::optional< mysql_harness::DestinationEndpoint > MySQLRoutingConnectionBase::destination_endpoint ( ) const

pure virtual

Implemented in MysqlRoutingClassicConnectionBase, and MysqlRoutingXConnection.

◆ disassociate()

void MySQLRoutingConnectionBase::disassociate ( )

inline

◆ disconnect()

virtual void MySQLRoutingConnectionBase::disconnect ( )

pure virtual

Implemented in MysqlRoutingClassicConnectionBase, and MysqlRoutingXConnection.

◆ disconnect_request()

template<class F >

auto MySQLRoutingConnectionBase::disconnect_request ( F && f )

inline

◆ disconnect_requested()

bool MySQLRoutingConnectionBase::disconnect_requested ( ) const

inline

◆ get_bytes_down()

std::size_t MySQLRoutingConnectionBase::get_bytes_down ( ) const

inline

◆ get_bytes_up()

std::size_t MySQLRoutingConnectionBase::get_bytes_up ( ) const

inline

◆ get_client_address()

std::string MySQLRoutingConnectionBase::get_client_address ( ) const

inline

Returns address of client which connected to router.

Returns: address of client

◆ get_client_fd()

virtual net::impl::socket::native_handle_type MySQLRoutingConnectionBase::get_client_fd ( ) const

pure virtual

Implemented in MysqlRoutingClassicConnectionBase, and MysqlRoutingXConnection.

◆ get_connected_to_server()

time_point_type MySQLRoutingConnectionBase::get_connected_to_server ( ) const

inline

◆ get_destination_id()

virtual std::optional< mysql_harness::Destination > MySQLRoutingConnectionBase::get_destination_id ( ) const

pure virtual

Implemented in MysqlRoutingClassicConnectionBase, and MysqlRoutingXConnection.

◆ get_last_received_from_server()

time_point_type MySQLRoutingConnectionBase::get_last_received_from_server ( ) const

inline

◆ get_last_sent_to_server()

time_point_type MySQLRoutingConnectionBase::get_last_sent_to_server ( ) const

inline

◆ get_routing_source()

virtual std::string MySQLRoutingConnectionBase::get_routing_source ( ) const

pure virtual

Implemented in MysqlRoutingClassicConnectionBase, and MysqlRoutingXConnection.

◆ get_server_address()

std::string MySQLRoutingConnectionBase::get_server_address ( ) const

inline

Returns address of server to which connection is established.

Returns: address of server

◆ get_server_info()

virtual routing_guidelines::Server_info MySQLRoutingConnectionBase::get_server_info ( ) const

pure virtual

Implemented in MysqlRoutingClassicConnectionBase, and MysqlRoutingXConnection.

◆ get_session_info()

routing_guidelines::Session_info MySQLRoutingConnectionBase::get_session_info ( ) const

◆ get_started()

time_point_type MySQLRoutingConnectionBase::get_started ( ) const

inline

◆ get_stats()

Stats MySQLRoutingConnectionBase::get_stats ( ) const

inline

◆ log_connection_summary()

void MySQLRoutingConnectionBase::log_connection_summary ( )

protected

◆ read_only_destination_endpoint()

virtual std::optional< mysql_harness::DestinationEndpoint > MySQLRoutingConnectionBase::read_only_destination_endpoint ( ) const

inlinevirtual

Reimplemented in MysqlRoutingClassicConnectionBase.

◆ read_only_destination_id()

virtual std::optional< mysql_harness::Destination > MySQLRoutingConnectionBase::read_only_destination_id ( ) const

inlinevirtual

Reimplemented in MysqlRoutingClassicConnectionBase.

◆ read_write_destination_endpoint()

virtual std::optional< mysql_harness::DestinationEndpoint > MySQLRoutingConnectionBase::read_write_destination_endpoint ( ) const

inlinevirtual

Reimplemented in MysqlRoutingClassicConnectionBase.

◆ read_write_destination_id()

virtual std::optional< mysql_harness::Destination > MySQLRoutingConnectionBase::read_write_destination_id ( ) const

inlinevirtual

Reimplemented in MysqlRoutingClassicConnectionBase.

◆ server_address()

void MySQLRoutingConnectionBase::server_address ( const std::string & dest )

inline

◆ set_routing_guidelines_session_rand()

void MySQLRoutingConnectionBase::set_routing_guidelines_session_rand ( )

◆ set_routing_source()

virtual void MySQLRoutingConnectionBase::set_routing_source ( std::string name )

pure virtual

Implemented in MysqlRoutingClassicConnectionBase, and MysqlRoutingXConnection.

◆ transfered_to_client()

void MySQLRoutingConnectionBase::transfered_to_client ( size_t bytes )

inline

◆ transfered_to_server()

void MySQLRoutingConnectionBase::transfered_to_server ( size_t bytes )

inline

◆ wait_until_completed()

virtual void MySQLRoutingConnectionBase::wait_until_completed ( )

pure virtual

Implemented in MysqlRoutingClassicConnectionBase, and MysqlRoutingXConnection.

Member Data Documentation

◆ client_fd_

net::impl::socket::native_handle_type MySQLRoutingConnectionBase::client_fd_

private

◆ context_

MySQLRoutingContext& MySQLRoutingConnectionBase::context_

protected

wrapper for common data used by all routing threads

◆ disconnect_

Monitor<bool> MySQLRoutingConnectionBase::disconnect_ {{}}

protected

◆ remove_callback_

std::function<void(MySQLRoutingConnectionBase *)> MySQLRoutingConnectionBase::remove_callback_

protected

callback that is called when thread of execution completes

◆ routing_guidelines_session_rand_

std::optional<double> MySQLRoutingConnectionBase::routing_guidelines_session_rand_

private

◆ stats_

Monitor<Stats> MySQLRoutingConnectionBase::stats_ {{}}

protected

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

router/src/routing/src/connection.h
router/src/routing/src/connection.cc

Classes

Public Types

Public Member Functions

Protected Member Functions

Protected Attributes

Private Attributes

Member Typedef Documentation

◆ clock_type

◆ time_point_type

Constructor & Destructor Documentation

◆ MySQLRoutingConnectionBase()

◆ ~MySQLRoutingConnectionBase()

Member Function Documentation

◆ accepted()

◆ client_address()

◆ completed()

◆ connected()

◆ context() [1/2]

◆ context() [2/2]

◆ destination_endpoint()

◆ disassociate()

◆ disconnect()

◆ disconnect_request()

◆ disconnect_requested()

◆ get_bytes_down()

◆ get_bytes_up()

◆ get_client_address()

◆ get_client_fd()

◆ get_connected_to_server()

◆ get_destination_id()

◆ get_last_received_from_server()

◆ get_last_sent_to_server()

◆ get_routing_source()

◆ get_server_address()

◆ get_server_info()

◆ get_session_info()

◆ get_started()

◆ get_stats()

◆ log_connection_summary()

◆ read_only_destination_endpoint()

◆ read_only_destination_id()

◆ read_write_destination_endpoint()

◆ read_write_destination_id()

◆ server_address()

◆ set_routing_guidelines_session_rand()

◆ set_routing_source()

◆ transfered_to_client()

◆ transfered_to_server()

◆ wait_until_completed()

Member Data Documentation

◆ client_fd_

◆ context_

◆ disconnect_

◆ remove_callback_

◆ routing_guidelines_session_rand_

◆ stats_