MySQLRoutingConnectionBase Class Reference

#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::string	get_destination_id () const =0
virtual std::string	read_only_destination_id () const
virtual std::string	read_write_destination_id () const
virtual std::optional< net::ip::tcp::endpoint >	destination_endpoint () const =0
virtual std::optional< net::ip::tcp::endpoint >	read_only_destination_endpoint () const
virtual std::optional< net::ip::tcp::endpoint >	read_write_destination_endpoint () const
virtual net::impl::socket::native_handle_type	get_client_fd () 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

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_

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

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< net::ip::tcp::endpoint > 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::string 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_server_address()

std::string MySQLRoutingConnectionBase::get_server_address ( ) const

inline

Returns address of server to which connection is established.

Returns

address of server

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< net::ip::tcp::endpoint > MySQLRoutingConnectionBase::read_only_destination_endpoint ( ) const

inlinevirtual

Reimplemented in MysqlRoutingClassicConnectionBase.

read_only_destination_id()

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

inlinevirtual

Reimplemented in MysqlRoutingClassicConnectionBase.

read_write_destination_endpoint()

virtual std::optional< net::ip::tcp::endpoint > MySQLRoutingConnectionBase::read_write_destination_endpoint ( ) const

inlinevirtual

Reimplemented in MysqlRoutingClassicConnectionBase.

read_write_destination_id()

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

inlinevirtual

Reimplemented in MysqlRoutingClassicConnectionBase.

server_address()

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

inline

transfered_to_client()

void MySQLRoutingConnectionBase::transfered_to_client ( size_t  bytes )

inline

transfered_to_server()

void MySQLRoutingConnectionBase::transfered_to_server ( size_t  bytes )

inline

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

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