abort_pos_wait | Relay_log_info | |
abort_slave | Rpl_info | |
adapt_to_master_version(Format_description_log_event *fdle) | Relay_log_info | |
adapt_to_master_version_updown(ulong master_version, ulong current_version) | Relay_log_info | |
add_channel_to_relay_log_name(char *buff, uint buff_size, const char *base_name) | Relay_log_info | private |
add_gtid_set(const Gtid_set *gtid_set) | Relay_log_info | |
add_logged_gtid(rpl_sidno sidno, rpl_gno gno) | Relay_log_info | inline |
APPLIER_METADATA_LINES_WITH_ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS_TYPE | Relay_log_info | privatestatic |
APPLIER_METADATA_LINES_WITH_ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS_VALUE | Relay_log_info | privatestatic |
APPLIER_METADATA_LINES_WITH_CHANNEL | Relay_log_info | privatestatic |
APPLIER_METADATA_LINES_WITH_DELAY | Relay_log_info | privatestatic |
APPLIER_METADATA_LINES_WITH_ID | Relay_log_info | privatestatic |
APPLIER_METADATA_LINES_WITH_PRIV_CHECKS_HOSTNAME | Relay_log_info | privatestatic |
APPLIER_METADATA_LINES_WITH_PRIV_CHECKS_USERNAME | Relay_log_info | privatestatic |
APPLIER_METADATA_LINES_WITH_REQUIRE_ROW_FORMAT | Relay_log_info | privatestatic |
APPLIER_METADATA_LINES_WITH_REQUIRE_TABLE_PRIMARY_KEY_CHECK | Relay_log_info | privatestatic |
APPLIER_METADATA_LINES_WITH_WORKERS | Relay_log_info | privatestatic |
assign_partition_db(Log_event *ev) | Slave_worker | private |
atomic_channel_open_temp_tables | Relay_log_info | |
atomic_is_stopping | Rpl_info | |
belongs_to_client() | Relay_log_info | inline |
bitmap_shifted | Slave_worker | |
c_rli | Slave_worker | |
cached_charset | Relay_log_info | |
cached_charset_compare(char *charset) const | Relay_log_info | |
cached_charset_invalidate() | Relay_log_info | |
channel | Rpl_info | protected |
channel_mts_submode | Relay_log_info | |
check_and_report_end_of_retries(THD *thd) | Slave_worker | |
check_applier_acl_user(char const *param_privilege_checks_username, char const *param_privilege_checks_hostname) | Relay_log_info | |
check_if_info_was_cleared(const enum_return_check &previous_result) const | Relay_log_info | |
check_info() const | Rpl_info | inline |
check_privilege_checks_user() | Relay_log_info | |
check_privilege_checks_user(char const *param_privilege_checks_username, char const *param_privilege_checks_hostname) | Relay_log_info | |
checkpoint_group | Relay_log_info | |
checkpoint_master_log_name | Slave_worker | |
checkpoint_master_log_pos | Slave_worker | |
checkpoint_notified | Slave_worker | |
checkpoint_relay_log_name | Slave_worker | |
checkpoint_relay_log_pos | Slave_worker | |
clean_info() | Rpl_info | inline |
cleanup_after_query() | Relay_log_info | inline |
cleanup_after_session() | Relay_log_info | inline |
cleanup_context(THD *, bool) | Relay_log_info | |
clear_error() | Slave_reporting_capability | inline |
clear_flag(enum_state_flag flag) | Relay_log_info | inline |
clear_gtid_monitoring_info() | Relay_log_info | inline |
clear_info() | Relay_log_info | |
clear_mts_recovery_groups() | Relay_log_info | inline |
clear_privilege_checks_user() | Relay_log_info | |
clear_processing_trx() | Relay_log_info | inline |
clear_relay_log_truncated() | Relay_log_info | |
clear_sql_delay() | Relay_log_info | inline |
clear_tables_to_lock() | Relay_log_info | |
clear_until_option() | Relay_log_info | inline |
close_temporary_tables() | Relay_log_info | |
commit_order_mngr | Relay_log_info | private |
commit_positions(Log_event *evt, Slave_job_group *ptr_g, bool force) | Slave_worker | |
commit_positions() override | Slave_worker | inlinevirtual |
commit_timestamps_status | Relay_log_info | |
COMMIT_TS_FOUND enum value | Relay_log_info | |
COMMIT_TS_NOT_FOUND enum value | Relay_log_info | |
COMMIT_TS_UNKNOWN enum value | Relay_log_info | |
coordinator_log_after_purge | Relay_log_info | |
copy_info(Rpl_info_handler *from, Rpl_info_handler *to) | Rpl_info | inline |
copy_values_for_PFS(ulong worker_id, en_running_state running_status, THD *worker_thd, const Error &last_error, Gtid_monitoring_info *monitoring_info_arg) | Slave_worker | |
copy_worker_metrics(Slave_worker *other) | Slave_worker | inline |
count_relay_log_space() | Relay_log_info | |
curr_group_assigned_parts | Relay_log_info | |
curr_group_da | Relay_log_info | |
curr_group_exec_parts | Slave_worker | |
curr_group_isolated | Relay_log_info | |
curr_group_seen_begin | Relay_log_info | |
curr_group_seen_gtid | Relay_log_info | |
curr_group_seen_sequence_number | Slave_worker | |
curr_jobs | Slave_worker | |
current_event | Relay_log_info | |
current_mts_submode | Relay_log_info | |
data_cond | Rpl_info | |
data_lock | Rpl_info | |
ddl_not_atomic | Relay_log_info | |
deferred_events | Relay_log_info | |
deferred_events_collecting | Relay_log_info | |
deinit_workers() | Relay_log_info | |
detach_engine_ha_data(THD *thd) | Relay_log_info | |
do_report(loglevel level, int err_code, const char *msg, va_list v_args) const override | Slave_worker | protectedvirtual |
do_report(loglevel level, int err_code, const Gtid_specification *gtid_next, const char *msg, va_list v_args) const override | Slave_worker | protectedvirtual |
en_running_state enum name | Slave_worker | |
end_group_sets_max_dbs | Slave_worker | |
end_info() | Slave_worker | private |
enum_priv_checks_status enum name | Relay_log_info | |
enum_require_row_status enum name | Relay_log_info | |
enum_require_table_primary_key enum name | Relay_log_info | |
enum_state_flag enum name | Relay_log_info | |
err_lock | Slave_reporting_capability | mutable |
ERROR_LEAVING enum value | Slave_worker | |
error_on_rli_init_info | Relay_log_info | |
event_relay_log_name | Relay_log_info | protected |
event_relay_log_pos | Relay_log_info | protected |
event_start_pos | Relay_log_info | protected |
excess_cnt | Slave_worker | |
exit_count_lock | Relay_log_info | |
exit_counter | Relay_log_info | |
exit_incremented | Slave_worker | |
fd_change_notified | Slave_worker | |
fill_coord_err_buf(loglevel level, int err_code, const char *buff_coord) const | Relay_log_info | |
finished_processing() | Relay_log_info | inline |
flush_current_log() | Relay_log_info | |
flush_info(bool force=false) | Slave_worker | |
Relay_log_info::flush_info(const int flush_flags) | Relay_log_info | |
force_flush_postponed_due_to_split_trans | Relay_log_info | |
found_commit_order_deadlock() | Slave_worker | |
future_event_relay_log_pos | Relay_log_info | protected |
gaq | Relay_log_info | |
gaq_index | Slave_worker | private |
get_allow_drop_write_set() | Relay_log_info | inline |
get_applier_metrics() | Relay_log_info | |
get_c_rli() override | Slave_worker | inlinevirtual |
get_channel() const | Rpl_info | inline |
get_channel_field_index() | Slave_worker | static |
get_commit_order_manager() | Relay_log_info | inline |
get_description_info() const | Rpl_info | inline |
get_event_relay_log_name() | Relay_log_info | inline |
get_event_relay_log_pos() | Relay_log_info | inline |
get_event_start_pos() | Relay_log_info | inline |
get_flag(enum_state_flag flag) | Relay_log_info | inline |
get_for_channel_str(bool upper_case=false) const override | Slave_worker | virtual |
get_future_event_relay_log_pos() | Relay_log_info | inline |
get_group_master_log_name() const | Relay_log_info | inline |
get_group_master_log_name_info() const | Relay_log_info | inline |
get_group_master_log_pos() const | Relay_log_info | inline |
get_group_master_log_pos_info() const | Relay_log_info | inline |
get_group_relay_log_name() | Relay_log_info | inline |
get_group_relay_log_pos() | Relay_log_info | inline |
get_group_source_log_start_end_pos() const | Relay_log_info | |
get_gtid_monitoring_info() | Relay_log_info | inline |
get_gtid_set() const | Relay_log_info | inline |
get_ignore_write_set_memory_limit() | Relay_log_info | inline |
get_internal_id() const | Rpl_info | inline |
get_master_log_name() | Slave_worker | |
get_master_log_pos() | Slave_worker | inline |
get_master_server_version() | Slave_worker | inline |
get_number_info_rli_fields() | Relay_log_info | static |
get_number_worker_fields() | Slave_worker | static |
get_privilege_checks_hostname() const | Relay_log_info | |
get_privilege_checks_username() const | Relay_log_info | |
get_require_table_primary_key_check() const | Relay_log_info | |
get_rli_description_event() const | Relay_log_info | inline |
get_row_stmt_start_timestamp() | Relay_log_info | inline |
get_rpl_info_handler() | Rpl_info | inline |
get_rpl_log_name() const | Relay_log_info | inline |
get_sql_delay() | Relay_log_info | inline |
get_sql_delay_end() | Relay_log_info | inline |
get_table_data(TABLE *table_arg, table_def **tabledef_var, TABLE **conv_table_var) const | Relay_log_info | inline |
get_table_pk_field_indexes() | Slave_worker | static |
get_thd_tx_priority() | Relay_log_info | inline |
get_tsid_lock() | Relay_log_info | inline |
get_tsid_map() | Relay_log_info | inline |
get_until_log_name() | Relay_log_info | |
get_until_log_pos() | Relay_log_info | |
get_worker(size_t n) | Relay_log_info | inline |
get_worker_count() | Relay_log_info | inline |
get_worker_metrics() | Slave_worker | |
group_executed | Slave_worker | |
group_master_log_name | Relay_log_info | protected |
group_master_log_pos | Relay_log_info | protected |
group_relay_log_name | Relay_log_info | protected |
group_relay_log_pos | Relay_log_info | protected |
group_shifted | Slave_worker | |
group_source_log_end_pos | Relay_log_info | private |
group_source_log_seen_start_pos | Relay_log_info | private |
group_source_log_start_pos | Relay_log_info | private |
gtid_monitoring_info | Relay_log_info | private |
gtid_retrieved_initialized | Relay_log_info | private |
gtid_set | Relay_log_info | private |
handler | Rpl_info | protected |
has_temporary_error(THD *thd, uint error_arg=0, bool *silent=nullptr) const | Slave_reporting_capability | |
id | Slave_worker | |
ign_master_log_name_end | Relay_log_info | |
ign_master_log_pos_end | Relay_log_info | |
IN_STMT enum value | Relay_log_info | |
inc_event_relay_log_pos() | Relay_log_info | inline |
inc_group_relay_log_pos(ulonglong log_pos, bool need_data_lock, bool force=false) | Relay_log_info | |
increment_worker_metrics_for_event(const Log_event &event) | Slave_worker | inline |
info_thd | Rpl_info | |
info_thd_lock | Rpl_info | |
init_until_option(THD *thd, const LEX_SOURCE_INFO *master_param) | Relay_log_info | |
init_worker(Relay_log_info *, ulong) | Slave_worker | |
init_workers(ulong) | Relay_log_info | |
inited | Rpl_info | |
inited_hash_workers | Relay_log_info | |
initialize_applier_security_context() | Relay_log_info | |
initialize_security_context(THD *thd) | Relay_log_info | |
internal_id | Rpl_info | protected |
is_applier_source_position_info_invalid() const | Relay_log_info | |
is_engine_ha_data_detached() | Relay_log_info | inline |
is_error() const | Slave_reporting_capability | inline |
is_group_master_log_pos_invalid | Relay_log_info | |
is_group_relay_log_name_invalid(const char **errmsg) | Relay_log_info | |
is_in_group() const | Relay_log_info | inline |
is_in_stmt() const | Relay_log_info | inlineprivate |
is_in_trx_or_stmt() const | Relay_log_info | inlineprivate |
is_long_find_row_note_printed() | Relay_log_info | inline |
is_mts_in_group() | Relay_log_info | inline |
is_mts_recovery() const | Relay_log_info | inline |
is_parallel_exec() const | Relay_log_info | inline |
is_privilege_checks_user_corrupted() const | Relay_log_info | |
is_privilege_checks_user_null() const | Relay_log_info | |
is_processing_trx() | Relay_log_info | inline |
is_receiver_waiting_for_rl_space | Relay_log_info | |
is_relay_log_recovery | Relay_log_info | |
is_relay_log_truncated() | Relay_log_info | inline |
is_row_format_required() const | Relay_log_info | |
is_time_for_mta_checkpoint() | Relay_log_info | |
is_transactional() const | Rpl_info | inline |
is_until_satisfied_after_dispatching_event() | Relay_log_info | inline |
is_until_satisfied_all_transactions_read_from_relay_log() | Relay_log_info | inline |
is_until_satisfied_at_start_slave() | Relay_log_info | inline |
is_until_satisfied_before_dispatching_event(const Log_event *ev) | Relay_log_info | inline |
jobs | Slave_worker | |
jobs_cond | Slave_worker | |
jobs_lock | Slave_worker | |
key_info_data_cond | Rpl_info | |
key_info_data_lock | Rpl_info | |
key_info_run_lock | Rpl_info | |
key_info_sleep_cond | Rpl_info | |
key_info_sleep_lock | Rpl_info | |
key_info_start_cond | Rpl_info | |
key_info_stop_cond | Rpl_info | |
key_info_thd_lock | Rpl_info | |
last_assigned_worker | Relay_log_info | |
last_clock | Relay_log_info | |
last_error() const | Slave_reporting_capability | inline |
last_event_start_time | Relay_log_info | |
last_group_done_index | Slave_worker | |
last_groups_assigned_index | Slave_worker | |
last_master_timestamp | Relay_log_info | |
log_space_cond | Relay_log_info | |
log_space_limit | Relay_log_info | |
log_space_lock | Relay_log_info | |
log_space_total | Relay_log_info | |
logical_clock_cond | Relay_log_info | |
long_find_row_note_printed | Relay_log_info | private |
m_allow_drop_write_set | Relay_log_info | private |
m_assign_gtids_to_anonymous_transactions_info | Relay_log_info | |
m_commit_order_deadlock | Slave_worker | private |
m_coordinator_metrics | Relay_log_info | private |
m_disabled_metric_aggregator | Relay_log_info | private |
m_disabled_worker_metrics | Slave_worker | private |
m_events_applied_in_transaction | Slave_worker | |
m_flag_positions_committed | Slave_worker | private |
m_flags | Relay_log_info | private |
m_ignore_write_set_memory_limit | Relay_log_info | private |
m_is_after_metrics_breakpoint | Slave_worker | |
m_is_applier_source_position_info_invalid | Relay_log_info | private |
m_is_engine_ha_data_detached | Relay_log_info | |
m_is_worker_metric_collection_enabled | Slave_worker | private |
m_key_mta_temp_table_LOCK | Relay_log_info | |
m_last_error | Slave_reporting_capability | mutableprotected |
m_privilege_checks_hostname | Relay_log_info | private |
m_privilege_checks_user_corrupted | Relay_log_info | private |
m_privilege_checks_username | Relay_log_info | private |
m_relay_log_truncated | Relay_log_info | private |
m_require_row_format | Relay_log_info | private |
m_require_table_primary_key_check | Relay_log_info | private |
m_table_map | Relay_log_info | |
m_thread_name | Slave_reporting_capability | private |
m_worker_metrics | Slave_worker | private |
mapping_db_to_worker | Relay_log_info | |
master_log_change_notified | Slave_worker | |
master_log_pos | Slave_worker | private |
max_updated_index | Relay_log_info | |
MAXIMUM_APPLIER_METADATA_LINES | Relay_log_info | privatestatic |
mi | Relay_log_info | |
mta_coordinator_has_waited_stat | Relay_log_info | |
mts_coordinator_basic_nap | Relay_log_info | |
MTS_END_GROUP enum value | Relay_log_info | |
mts_end_group_sets_max_dbs | Relay_log_info | |
mts_finalize_recovery() | Relay_log_info | |
mts_gaq_LOCK | Relay_log_info | |
mts_group_status | Relay_log_info | |
mts_groups_assigned | Relay_log_info | |
MTS_IN_GROUP enum value | Relay_log_info | |
MTS_KILLED_GROUP enum value | Relay_log_info | |
MTS_NOT_IN_GROUP enum value | Relay_log_info | |
mts_pending_jobs_size | Relay_log_info | |
mts_pending_jobs_size_max | Relay_log_info | |
mts_recovery_group_cnt | Relay_log_info | |
mts_recovery_group_seen_begin | Relay_log_info | |
mts_recovery_index | Relay_log_info | |
mts_slave_worker_queue_len_max | Relay_log_info | |
mts_temp_table_LOCK | Relay_log_info | |
mts_worker_underrun_level | Relay_log_info | |
mts_wq_excess_cnt | Relay_log_info | |
mts_wq_oversize | Relay_log_info | |
mts_wq_underrun_w_id | Relay_log_info | |
new_group_master_log_name | Relay_log_info | |
new_group_master_log_pos | Relay_log_info | |
new_group_relay_log_name | Relay_log_info | |
new_group_relay_log_pos | Relay_log_info | |
NOT_RUNNING enum value | Slave_worker | |
notify_group_master_log_name_update() | Relay_log_info | inline |
notify_relay_log_change() | Relay_log_info | inline |
notify_relay_log_truncated() | Relay_log_info | |
operator=(const Slave_worker &info) | Slave_worker | private |
opt_replica_parallel_workers | Relay_log_info | |
original_commit_timestamp | Relay_log_info | |
overrun_level | Slave_worker | |
pending_jobs | Relay_log_info | |
pending_jobs_cond | Relay_log_info | |
pending_jobs_lock | Relay_log_info | |
PK_CHECK_GENERATE enum value | Relay_log_info | |
PK_CHECK_NONE enum value | Relay_log_info | |
PK_CHECK_OFF enum value | Relay_log_info | |
PK_CHECK_ON enum value | Relay_log_info | |
PK_CHECK_STREAM enum value | Relay_log_info | |
post_commit(bool on_rollback) override | Slave_worker | inlinevirtual |
post_rollback() | Relay_log_info | inline |
pre_commit() | Relay_log_info | inline |
prepare_for_retry(Log_event &event) | Slave_worker | |
print_applier_security_context_user_host() const | Relay_log_info | |
PRIV_CHECKS_HOSTNAME_LENGTH | Relay_log_info | privatestatic |
PRIV_CHECKS_USERNAME_LENGTH | Relay_log_info | privatestatic |
purge_relay_logs(THD *thd, const char **errmsg, bool delete_only=false) | Relay_log_info | |
read_and_apply_events(my_off_t start_relay_pos, const char *start_event_relay_log_name, my_off_t end_relay_pos, const char *end_event_relay_log_name) | Slave_worker | private |
read_info(Rpl_info_handler *from) override | Slave_worker | privatevirtual |
reattach_engine_ha_data(THD *thd) | Relay_log_info | |
recovery_groups | Relay_log_info | |
recovery_groups_inited | Relay_log_info | |
recovery_parallel_workers | Relay_log_info | |
reinit_sql_thread_io_cache(const char *log, bool need_data_lock) | Relay_log_info | |
relay_log | Relay_log_info | |
relay_log_change_notified | Slave_worker | |
Relay_log_info(bool is_slave_recovery, PSI_mutex_key *param_key_info_run_lock, PSI_mutex_key *param_key_info_data_lock, PSI_mutex_key *param_key_info_sleep_lock, PSI_mutex_key *param_key_info_thd_lock, PSI_mutex_key *param_key_info_data_cond, PSI_mutex_key *param_key_info_start_cond, PSI_mutex_key *param_key_info_stop_cond, PSI_mutex_key *param_key_info_sleep_cond, uint param_id, const char *param_channel, bool is_rli_fake) | Relay_log_info | |
Relay_log_info(const Relay_log_info &info) | Relay_log_info | private |
relay_log_sanitized | Relay_log_info | private |
remove_info() | Rpl_info | inline |
replica_parallel_workers | Relay_log_info | |
replicate_same_server_id | Relay_log_info | |
report(loglevel level, int err_code, const char *msg,...) const | Slave_reporting_capability | virtual |
report(loglevel level, int err_code, const Gtid_specification *gtid_next, const char *msg,...) const | Slave_reporting_capability | virtual |
report_commit_order_deadlock() | Slave_worker | |
report_privilege_check_error(enum loglevel level, enum_priv_checks_status status_code, bool to_client, char const *channel_name=nullptr, char const *user_name=nullptr, char const *host_name=nullptr) const | Relay_log_info | |
reported_unsafe_warning | Relay_log_info | |
reset_commit_order_deadlock() | Slave_worker | |
reset_gaq_index() | Slave_worker | inline |
reset_group_relay_log_pos(const char **errmsg) | Relay_log_info | |
reset_notified_checkpoint(ulong count, time_t new_ts, bool update_timestamp=false) | Relay_log_info | |
reset_notified_relay_log_change() | Relay_log_info | |
reset_recovery_info() | Slave_worker | |
reset_row_stmt_start_timestamp() | Relay_log_info | inline |
retried_processing(uint transient_errno_arg, const char *transient_err_message_arg, ulong trans_retries_arg) | Relay_log_info | inline |
retried_trans | Relay_log_info | |
retry_transaction(my_off_t start_relay_pos, const char *start_event_relay_log_name, my_off_t end_relay_pos, const char *end_event_relay_log_name) | Slave_worker | |
rli_checkpoint_seqno | Relay_log_info | |
rli_description_event | Relay_log_info | protected |
rli_fake | Relay_log_info | private |
RLI_FLUSH_IGNORE_GTID_ONLY | Relay_log_info | static |
RLI_FLUSH_IGNORE_SYNC_OPT | Relay_log_info | static |
RLI_FLUSH_NO_OPTION | Relay_log_info | static |
rli_init_info(bool) | Slave_worker | |
rollback_positions(Slave_job_group *ptr_g) | Slave_worker | |
row_stmt_start_timestamp | Relay_log_info | private |
rows_query_ev | Relay_log_info | |
rpl_filter | Relay_log_info | |
Rpl_info(const char *type, PSI_mutex_key *param_key_info_run_lock, PSI_mutex_key *param_key_info_data_lock, PSI_mutex_key *param_key_info_sleep_lock, PSI_mutex_key *param_key_info_thd_lock, PSI_mutex_key *param_key_info_data_cond, PSI_mutex_key *param_key_info_start_cond, PSI_mutex_key *param_key_info_stop_cond, PSI_mutex_key *param_key_info_sleep_cond, uint param_id, const char *param_channel) | Rpl_info | protected |
Rpl_info(const Rpl_info &info) | Rpl_info | private |
run_lock | Rpl_info | |
RUNNING enum value | Slave_worker | |
running_status | Slave_worker | |
save_temporary_tables | Relay_log_info | |
sequence_number() | Slave_worker | inline |
server_version | Slave_worker | |
set_allow_drop_write_set(bool does_not_require_ws) | Relay_log_info | inline |
set_applier_source_position_info_invalid(bool invalid) | Relay_log_info | |
set_commit_order_manager(Commit_order_manager *mngr) | Relay_log_info | inline |
set_event_relay_log_name(const char *log_file_name) | Relay_log_info | inline |
set_event_relay_log_pos(ulonglong log_pos) | Relay_log_info | inline |
set_event_start_pos(my_off_t pos) | Relay_log_info | inline |
set_filter(Rpl_filter *channel_filter) | Relay_log_info | inline |
set_flag(enum_state_flag flag) | Relay_log_info | inline |
set_future_event_relay_log_pos(ulonglong log_pos) | Relay_log_info | inline |
set_gaq_index(ulong val) | Slave_worker | inline |
set_group_master_log_name(const char *log_file_name) | Relay_log_info | inline |
set_group_master_log_pos(ulonglong log_pos) | Relay_log_info | inline |
set_group_relay_log_name(const char *log_file_name) | Relay_log_info | inline |
set_group_relay_log_name(const char *log_file_name, size_t len) | Relay_log_info | inline |
set_group_relay_log_pos(ulonglong log_pos) | Relay_log_info | inline |
set_group_source_log_start_end_pos(const Log_event *ev) | Relay_log_info | |
set_ignore_write_set_memory_limit(bool ignore_limit) | Relay_log_info | inline |
set_info_search_keys(Rpl_info_handler *to) override | Slave_worker | virtual |
set_long_find_row_note_printed() | Relay_log_info | inline |
set_master_info(Master_info *info) | Relay_log_info | |
set_master_log_pos(ulong val) | Slave_worker | inline |
set_nullable_fields(MY_BITMAP *nullable_fields) | Slave_worker | static |
set_privilege_checks_user(char const *param_privilege_checks_username, char const *param_privilege_checks_hostname) | Relay_log_info | |
set_privilege_checks_user_corrupted(bool is_corrupted) | Relay_log_info | |
set_require_row_format(bool require_row) | Relay_log_info | |
set_require_table_primary_key_check(enum_require_table_primary_key require_pk) | Relay_log_info | |
set_rli_description_event(Format_description_log_event *fdle) override | Slave_worker | inlinevirtual |
set_row_stmt_start_timestamp() | Relay_log_info | inline |
set_rpl_info_handler(Rpl_info_handler *param_handler) | Rpl_info | inline |
set_sql_delay(time_t _sql_delay) | Relay_log_info | inline |
set_thd_tx_priority(int priority) | Relay_log_info | inline |
set_until_option(Until_option *option) | Relay_log_info | inline |
set_worker_metric_collection_status(bool status) | Slave_worker | inline |
slave_close_thread_tables(THD *) | Relay_log_info | |
slave_patternload_file | Relay_log_info | |
slave_patternload_file_size | Relay_log_info | |
Slave_reporting_capability(char const *thread_name) | Slave_reporting_capability | |
Slave_reporting_capability(const Slave_reporting_capability &rhs) | Slave_reporting_capability | private |
slave_run_id | Rpl_info | |
slave_running | Rpl_info | |
slave_skip_counter | Relay_log_info | |
slave_version_split | Relay_log_info | |
Slave_worker(Relay_log_info *rli, PSI_mutex_key *param_key_info_run_lock, PSI_mutex_key *param_key_info_data_lock, PSI_mutex_key *param_key_info_sleep_lock, PSI_mutex_key *param_key_info_thd_lock, PSI_mutex_key *param_key_info_data_cond, PSI_mutex_key *param_key_info_start_cond, PSI_mutex_key *param_key_info_stop_cond, PSI_mutex_key *param_key_info_sleep_cond, uint param_id, const char *param_channel) | Slave_worker | |
Slave_worker(const Slave_worker &info) | Slave_worker | private |
slave_worker_ends_group(Log_event *, int) | Slave_worker | |
slave_worker_exec_event(Log_event *ev) | Slave_worker | |
slave_worker_hash_cond | Relay_log_info | |
slave_worker_hash_lock | Relay_log_info | |
sleep_cond | Rpl_info | |
sleep_lock | Rpl_info | |
sql_delay | Relay_log_info | private |
sql_delay_end | Relay_log_info | private |
sql_thread_kill_accepted | Relay_log_info | |
start_cond | Rpl_info | |
start_sql_delay(time_t delay_end) | Relay_log_info | |
started_processing(Gtid gtid_arg, ulonglong original_ts_arg, ulonglong immediate_ts_arg, bool skipped=false) | Relay_log_info | inline |
started_processing(Gtid_log_event *gtid_log_ev_arg) | Relay_log_info | inline |
STATE_FLAGS_COUNT enum value | Relay_log_info | |
stmt_done(my_off_t event_log_pos) | Relay_log_info | |
STOP enum value | Slave_worker | |
STOP_ACCEPTED enum value | Slave_worker | |
stop_cond | Rpl_info | |
tables_to_lock | Relay_log_info | |
tables_to_lock_count | Relay_log_info | |
thd_tx_priority | Relay_log_info | private |
trans_retries | Relay_log_info | |
transaction_parser | Relay_log_info | |
transactions_handled | Slave_worker | |
underrun_level | Slave_worker | |
unset_long_find_row_note_printed() | Relay_log_info | inline |
until_condition | Relay_log_info | |
UNTIL_DONE enum value | Relay_log_info | |
UNTIL_MASTER_POS enum value | Relay_log_info | |
UNTIL_NONE enum value | Relay_log_info | |
until_option | Relay_log_info | private |
UNTIL_RELAY_POS enum value | Relay_log_info | |
UNTIL_SQL_AFTER_GTIDS enum value | Relay_log_info | |
UNTIL_SQL_AFTER_MTS_GAPS enum value | Relay_log_info | |
UNTIL_SQL_BEFORE_GTIDS enum value | Relay_log_info | |
UNTIL_SQL_VIEW_ID enum value | Relay_log_info | |
update_is_transactional() | Rpl_info | inline |
usage_partition | Slave_worker | |
va_report(loglevel level, int err_code, const char *prefix_msg, const char *msg, va_list v_args) const | Slave_reporting_capability | |
wait_for_gtid_set(THD *thd, const char *gtid, double timeout, bool update_THD_status=true) | Relay_log_info | |
wait_for_gtid_set(THD *thd, String *gtid, double timeout, bool update_THD_status=true) | Relay_log_info | |
wait_for_gtid_set(THD *thd, const Gtid_set *wait_gtid_set, double timeout, bool update_THD_status=true) | Relay_log_info | |
wait_for_pos(THD *thd, String *log_name, longlong log_pos, double timeout) | Relay_log_info | |
worker_checkpoint_seqno | Slave_worker | |
worker_queue_mem_exceeded_count | Relay_log_info | |
worker_sleep(ulong seconds) | Slave_worker | private |
workers | Relay_log_info | |
workers_array_initialized | Relay_log_info | |
workers_copy_pfs | Relay_log_info | |
wq_overrun_cnt | Slave_worker | |
write_info(Rpl_info_handler *to) override | Slave_worker | privatevirtual |
~Relay_log_info() override | Relay_log_info | |
~Rpl_info() override | Rpl_info | |
~Slave_reporting_capability()=0 | Slave_reporting_capability | pure virtual |
~Slave_worker() override | Slave_worker | |