MySQL 8.4.2
Source Code Documentation
KillForwarder Member List

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

BasicProcessor(MysqlRoutingClassicConnectionBase *conn)Processorinline
client_socket_failed(std::error_code ec)Processorprotected
command()KillForwarderprivate
conn_BasicProcessorprivate
connect()KillForwarderprivate
connect_error_is_transient(const classic_protocol::message::server::Error &err)ForwardingProcessorprotectedstatic
connected()KillForwarderprivate
connection() constBasicProcessorinline
connection()BasicProcessorinline
discard_current_msg(Channel &src_channel, ClassicProtocolState &src_protocol)Processorprotected
discard_current_msg(TlsSwitchableConnection< Proto > &conn)Processorinlineprotected
error()KillForwarderprivate
forward()KillForwarderprivate
forward_client_to_server(bool noflush=false)ForwardingProcessorprotected
forward_done()KillForwarderprivate
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()KillForwarderprivate
pool_server_connection()ForwardingProcessorprotected
prefix()KillForwarderinlinestatic
process() overrideKillForwardervirtual
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()KillForwarderprivate
Result enum nameBasicProcessor
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 enum nameKillForwarder
stage(Stage stage)KillForwarderinline
stage() constKillForwarderinline
stage_KillForwarderprivate
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_KillForwarderprivate
trace_event_connect_and_forward_command_KillForwarderprivate
trace_event_forward_command_KillForwarderprivate
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