MySQL 8.4.2
Source Code Documentation
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