MySQL 9.2.0
Source Code Documentation
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Modules Pages Concepts
QueryForwarder Member List

This is the complete list of members for QueryForwarder, including all inherited members.

BasicProcessor(MysqlRoutingClassicConnectionBase *conn)Processorinline
classify_query()QueryForwarderprivate
client_socket_failed(std::error_code ec)Processorprotected
column()QueryForwarderprivate
column_count()QueryForwarderprivate
column_end()QueryForwarderprivate
columns_left_QueryForwarderprivate
command()QueryForwarderprivate
conn_BasicProcessorprivate
connect()QueryForwarderprivate
connect_error_is_transient(const classic_protocol::message::server::Error &err)ForwardingProcessorprotectedstatic
connected()QueryForwarderprivate
connection() constBasicProcessorinline
connection()BasicProcessorinline
data()QueryForwarderprivate
discard_current_msg(Channel &src_channel, ClassicProtocolState &src_protocol)Processorprotected
discard_current_msg(TlsSwitchableConnection< Proto > &conn)Processorinlineprotected
error()QueryForwarderprivate
explicit_commit()QueryForwarderprivate
explicit_commit_connect()QueryForwarderprivate
explicit_commit_connect_done()QueryForwarderprivate
explicit_commit_done()QueryForwarderprivate
failed(const std::optional< classic_protocol::message::server::Error > &err)QueryForwarderinline
failed() constQueryForwarderinline
failed_QueryForwarderprivate
forward()QueryForwarderprivate
forward_client_to_server(bool noflush=false)ForwardingProcessorprotected
forward_done()QueryForwarderprivate
forward_server_to_client(bool noflush=false)ForwardingProcessorprotected
kConnectRetryIntervalForwardingProcessorstatic
load_data()QueryForwarderprivate
log_fatal_error_code(const char *msg, std::error_code ec)Processorprotectedstatic
message_can_be_forwarded_as_is(ClassicProtocolState &src_protocol, ClassicProtocolState &dst_protocol, const T &msg)ForwardingProcessorinlineprotectedstatic
mysql_reconnect_start(TraceEvent *parent_event)ForwardingProcessorprotected
ok()QueryForwarderprivate
pool_server_connection()ForwardingProcessorprotected
prefix()QueryForwarderinlinestatic
prepare_backend()QueryForwarderprivate
process() overrideQueryForwardervirtual
reconnect_error(classic_protocol::message::server::Error err)ForwardingProcessorinlineprotected
reconnect_error() constForwardingProcessorinlineprotected
reconnect_error_ForwardingProcessorprivate
reconnect_send_error_msg(Channel &src_channel, ClassicProtocolState &src_protocol)ForwardingProcessorprotected
reconnect_send_error_msg(TlsSwitchableConnection< Proto > &conn)ForwardingProcessorinlineprotected
recv_client_failed(std::error_code ec)Processorprotected
recv_server_failed(std::error_code ec)Processorprotected
recv_server_failed_and_check_client_socket(std::error_code ec)ForwardingProcessorprotected
response()QueryForwarderprivate
response_done()QueryForwarderprivate
Result enum nameBasicProcessor
row()QueryForwarderprivate
row_end()QueryForwarderprivate
row_or_end()QueryForwarderprivate
send_client_failed(std::error_code ec)Processorprotected
send_queued()QueryForwarderprivate
send_server_failed(std::error_code ec)Processorprotected
server_socket_failed(std::error_code ec)Processorprotected
skip_or_inject_end_of_columns(bool no_flush=false)ForwardingProcessorprotected
socket_reconnect_start(TraceEvent *parent_event)ForwardingProcessorprotected
sql_parser_state_QueryForwarderprivate
Stage enum nameQueryForwarder
stage(Stage stage)QueryForwarderinline
stage() constQueryForwarderinline
stage_QueryForwarderprivate
stmt_classified_QueryForwarderprivate
switch_backend()QueryForwarderprivate
trace(Tracer::Event e)Processorprotected
trace_command(const std::string_view &prefix)Processorprotected
trace_command_end(TraceEvent *event, TraceEvent::StatusCode status_code=TraceEvent::StatusCode::kUnset)Processorprotected
trace_connect(TraceEvent *parent_span)Processorprotected
trace_connect_and_explicit_commit(TraceEvent *parent_span)QueryForwarderprivate
trace_connect_and_forward_command(TraceEvent *parent_span)Processorprotected
trace_event_command_QueryForwarderprivate
trace_event_connect_and_explicit_commit_QueryForwarderprivate
trace_event_connect_and_forward_command_QueryForwarderprivate
trace_event_forward_command_QueryForwarderprivate
trace_event_query_result_QueryForwarderprivate
trace_forward_command(TraceEvent *parent_span)Processorprotected
trace_set_connection_attributes(TraceEvent *ev)Processorprotected
trace_span(TraceEvent *parent_span, const std::string_view &prefix)Processorprotected
trace_span_end(TraceEvent *event, TraceEvent::StatusCode status_code=TraceEvent::StatusCode::kUnset)Processorprotected
tracer()Processorprotected
track_session_changes(net::const_buffer session_trackers, classic_protocol::capabilities::value_type caps)QueryForwarderprivate
~BasicProcessor()=defaultBasicProcessorvirtual