anonymous_namespace{classic_query_forwarder.cc} Namespace Reference

Classes
class	FailedQueryHandler
class	ForwardedShowWarningCountHandler
class	ForwardedShowWarningsHandler
class	InterceptedStatementsParser
class	Name_string

Functions
std::string	string_from_timepoint (std::chrono::time_point< std::chrono::system_clock > tp)
	format a timepoint as json-value (date-time format). More...
std::string	to_string (stdx::flags< StmtClassifier > flags)
bool	contains_multiple_statements (SqlLexer &&lexer)
stdx::flags< StmtClassifier >	classify (SqlLexer &&lexer, bool forbid_set_trackers, bool config_access_mode_auto)
uint64_t	get_error_count (MysqlRoutingClassicConnectionBase *connection)
uint64_t	get_warning_count (MysqlRoutingClassicConnectionBase *connection)
stdx::expected< void, std::error_code >	send_resultset (MysqlRoutingClassicConnectionBase::ClientSideConnection &conn, const std::vector< classic_protocol::message::server::ColumnMeta > &columns, const std::vector< classic_protocol::message::server::Row > &rows)
stdx::expected< void, std::error_code >	trace_as_json (const TraceSpan &event_time_series, rapidjson::PrettyWriter< rapidjson::StringBuffer > &writer, const TraceEvent &event)
stdx::expected< std::string, std::error_code >	trace_as_json (const TraceSpan &event_time_series)
std::vector< classic_protocol::message::server::Row >	rows_from_warnings (MysqlRoutingClassicConnectionBase *connection, ShowWarnings::Verbosity verbosity, uint64_t row_count, uint64_t offset)
stdx::expected< void, std::error_code >	show_count (MysqlRoutingClassicConnectionBase *connection, const char *name, uint64_t count)
const char *	show_warning_count_name (ShowWarningCount::Verbosity verbosity, ShowWarningCount::Scope scope)
stdx::expected< void, std::error_code >	show_warning_count (MysqlRoutingClassicConnectionBase *connection, ShowWarningCount::Verbosity verbosity, ShowWarningCount::Scope scope)
stdx::expected< void, std::error_code >	show_warnings (MysqlRoutingClassicConnectionBase *connection, ShowWarnings::Verbosity verbosity, uint64_t row_count, uint64_t offset)
stdx::expected< void, std::error_code >	execute_command_router_set_trace (MysqlRoutingClassicConnectionBase *connection, const CommandRouterSet &cmd)
stdx::expected< void, std::error_code >	execute_command_router_set_access_mode (MysqlRoutingClassicConnectionBase *connection, const CommandRouterSet &cmd)
stdx::expected< void, std::error_code >	execute_command_router_set_wait_for_my_writes (MysqlRoutingClassicConnectionBase *connection, const CommandRouterSet &cmd)
stdx::expected< void, std::error_code >	execute_command_router_set_wait_for_my_writes_timeout (MysqlRoutingClassicConnectionBase *connection, const CommandRouterSet &cmd)
stdx::expected< void, std::error_code >	execute_command_router_set (MysqlRoutingClassicConnectionBase *connection, const CommandRouterSet &cmd)
stdx::expected< std::variant< std::monostate, ShowWarningCount, ShowWarnings, CommandRouterSet >, std::string >	intercept_diagnostics_area_queries (SqlLexer &&lexer)
stdx::expected< std::variant< std::monostate, StartTransaction >, std::string >	start_transaction (SqlLexer &&lexer)
stdx::expected< SplittingAllowedParser::Allowed, std::string >	splitting_allowed (SqlLexer &&lexer)
stdx::expected< bool, std::string >	is_implicitly_committed (SqlLexer &&lexer, std::optional< classic_protocol::session_track::TransactionState > trx_state)
bool	ends_with (std::string_view haystack, std::string_view needle)
bool	set_transaction_contains_read_only (std::optional< classic_protocol::session_track::TransactionCharacteristics > trx_char)

Variables
const auto	forwarded_status_flags

Function Documentation

classify()

stdx::flags< StmtClassifier > anonymous_namespace{classic_query_forwarder.cc}::classify	(	SqlLexer &&	lexer,
		bool	forbid_set_trackers,
		bool	config_access_mode_auto
	)

contains_multiple_statements()

bool anonymous_namespace{classic_query_forwarder.cc}::contains_multiple_statements

(

SqlLexer &&

lexer

)

ends_with()

bool anonymous_namespace{classic_query_forwarder.cc}::ends_with	(	std::string_view	haystack,
		std::string_view	needle
	)

execute_command_router_set()

stdx::expected< void, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::execute_command_router_set	(	MysqlRoutingClassicConnectionBase *	connection,
		const CommandRouterSet &	cmd
	)

execute_command_router_set_access_mode()

stdx::expected< void, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::execute_command_router_set_access_mode	(	MysqlRoutingClassicConnectionBase *	connection,
		const CommandRouterSet &	cmd
	)

execute_command_router_set_trace()

stdx::expected< void, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::execute_command_router_set_trace	(	MysqlRoutingClassicConnectionBase *	connection,
		const CommandRouterSet &	cmd
	)

execute_command_router_set_wait_for_my_writes()

stdx::expected< void, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::execute_command_router_set_wait_for_my_writes	(	MysqlRoutingClassicConnectionBase *	connection,
		const CommandRouterSet &	cmd
	)

execute_command_router_set_wait_for_my_writes_timeout()

stdx::expected< void, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::execute_command_router_set_wait_for_my_writes_timeout	(	MysqlRoutingClassicConnectionBase *	connection,
		const CommandRouterSet &	cmd
	)

get_error_count()

uint64_t anonymous_namespace{classic_query_forwarder.cc}::get_error_count

(

MysqlRoutingClassicConnectionBase *

connection

)

get_warning_count()

uint64_t anonymous_namespace{classic_query_forwarder.cc}::get_warning_count

(

MysqlRoutingClassicConnectionBase *

connection

)

intercept_diagnostics_area_queries()

stdx::expected< std::variant< std::monostate, ShowWarningCount, ShowWarnings, CommandRouterSet >, std::string > anonymous_namespace{classic_query_forwarder.cc}::intercept_diagnostics_area_queries

(

SqlLexer &&

lexer

)

is_implicitly_committed()

stdx::expected< bool, std::string > anonymous_namespace{classic_query_forwarder.cc}::is_implicitly_committed	(	SqlLexer &&	lexer,
		std::optional< classic_protocol::session_track::TransactionState >	trx_state
	)

rows_from_warnings()

std::vector< classic_protocol::message::server::Row > anonymous_namespace{classic_query_forwarder.cc}::rows_from_warnings	(	MysqlRoutingClassicConnectionBase *	connection,
		ShowWarnings::Verbosity	verbosity,
		uint64_t	row_count,
		uint64_t	offset
	)

send_resultset()

stdx::expected< void, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::send_resultset	(	MysqlRoutingClassicConnectionBase::ClientSideConnection &	conn,
		const std::vector< classic_protocol::message::server::ColumnMeta > &	columns,
		const std::vector< classic_protocol::message::server::Row > &	rows
	)

set_transaction_contains_read_only()

bool anonymous_namespace{classic_query_forwarder.cc}::set_transaction_contains_read_only

(

std::optional< classic_protocol::session_track::TransactionCharacteristics >

trx_char

)

show_count()

stdx::expected< void, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::show_count	(	MysqlRoutingClassicConnectionBase *	connection,
		const char *	name,
		uint64_t	count
	)

show_warning_count()

stdx::expected< void, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::show_warning_count	(	MysqlRoutingClassicConnectionBase *	connection,
		ShowWarningCount::Verbosity	verbosity,
		ShowWarningCount::Scope	scope
	)

show_warning_count_name()

const char * anonymous_namespace{classic_query_forwarder.cc}::show_warning_count_name	(	ShowWarningCount::Verbosity	verbosity,
		ShowWarningCount::Scope	scope
	)

show_warnings()

stdx::expected< void, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::show_warnings	(	MysqlRoutingClassicConnectionBase *	connection,
		ShowWarnings::Verbosity	verbosity,
		uint64_t	row_count,
		uint64_t	offset
	)

splitting_allowed()

stdx::expected< SplittingAllowedParser::Allowed, std::string > anonymous_namespace{classic_query_forwarder.cc}::splitting_allowed

(

SqlLexer &&

lexer

)

start_transaction()

stdx::expected< std::variant< std::monostate, StartTransaction >, std::string > anonymous_namespace{classic_query_forwarder.cc}::start_transaction

(

SqlLexer &&

lexer

)

string_from_timepoint()

std::string anonymous_namespace{classic_query_forwarder.cc}::string_from_timepoint

(

std::chrono::time_point< std::chrono::system_clock >

tp

)

format a timepoint as json-value (date-time format).

to_string()

std::string anonymous_namespace{classic_query_forwarder.cc}::to_string

(

stdx::flags< StmtClassifier >

flags

)

trace_as_json() [1/2]

stdx::expected< std::string, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::trace_as_json

(

const TraceSpan &

event_time_series

)

trace_as_json() [2/2]

stdx::expected< void, std::error_code > anonymous_namespace{classic_query_forwarder.cc}::trace_as_json	(	const TraceSpan &	event_time_series,
		rapidjson::PrettyWriter< rapidjson::StringBuffer > &	writer,
		const TraceEvent &	event
	)

Variable Documentation

forwarded_status_flags

const auto anonymous_namespace{classic_query_forwarder.cc}::forwarded_status_flags

Initial value:

=
    classic_protocol::status::in_transaction |
    classic_protocol::status::in_transaction_readonly |
    classic_protocol::status::autocommit