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

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

BasicProcessor(MysqlRoutingClassicConnectionBase *conn)Processorinline
client_socket_failed(std::error_code ec)Processorprotected
column()StmtExecuteForwarderprivate
column_count()StmtExecuteForwarderprivate
command()StmtExecuteForwarderprivate
conn_BasicProcessorprivate
connect_error_is_transient(const classic_protocol::message::server::Error &err)ForwardingProcessorprotectedstatic
connection() constBasicProcessorinline
connection()BasicProcessorinline
discard_current_msg(Channel &src_channel, ClassicProtocolState &src_protocol)Processorprotected
discard_current_msg(TlsSwitchableConnection< Proto > &conn)Processorinlineprotected
end_of_columns()StmtExecuteForwarderprivate
end_of_rows()StmtExecuteForwarderprivate
error()StmtExecuteForwarderprivate
forward()StmtExecuteForwarderprivate
forward_client_to_server(bool noflush=false)ForwardingProcessorprotected
forward_done()StmtExecuteForwarderprivate
forward_server_to_client(bool noflush=false)ForwardingProcessorprotected
kConnectRetryIntervalForwardingProcessorstatic
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()StmtExecuteForwarderprivate
pool_server_connection()ForwardingProcessorprotected
prefix()StmtExecuteForwarderinlinestatic
process() overrideStmtExecuteForwardervirtual
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()StmtExecuteForwarderprivate
Result enum nameBasicProcessor
row()StmtExecuteForwarderprivate
send_client_failed(std::error_code ec)Processorprotected
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
stage(Stage stage)StmtExecuteForwarderinline
stage() constStmtExecuteForwarderinline
Stage enum nameStmtExecuteForwarder
stage_StmtExecuteForwarderprivate
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_forward_command(TraceEvent *parent_span)Processorprotected
trace_event_command_StmtExecuteForwarderprivate
trace_event_connect_and_forward_command_StmtExecuteForwarderprivate
trace_event_forward_command_StmtExecuteForwarderprivate
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
~BasicProcessor()=defaultBasicProcessorvirtual