delete_credential(const char *channel_name) | Replication_thread_api | static |
get_applier_thread_ids(unsigned long **thread_ids) | Replication_thread_api | |
get_channel_credentials(std::string &username, std::string &password, const char *channel_name=nullptr) | Replication_thread_api | |
get_channel_network_namespace(std::string &net_ns, const char *channel_name=nullptr) | Replication_thread_api | |
get_last_delivered_gno(rpl_sidno sidno) | Replication_thread_api | |
get_retrieved_gtid_set(std::string &retrieved_set, const char *channel_name=nullptr) | Replication_thread_api | |
initialize_channel(char *hostname, uint port, char *user, char *password, bool use_ssl, char *ssl_ca, char *ssl_capath, char *ssl_cert, char *ssl_cipher, char *ssl_key, char *ssl_crl, char *ssl_crlpath, bool ssl_verify_server_cert, int priority, int retry_count, bool preserve_logs, char *public_key_path, bool get_public_key, char *compression_algorithm, uint zstd_compression_level, char *tls_version, char *tls_ciphersuites, bool ignore_ws_mem_limit, bool allow_drop_write_set) | Replication_thread_api | |
interface_channel | Replication_thread_api | private |
is_any_channel_using_uuid_for_assign_gtids_to_anonymous_transaction(const char *uuid_param) | Replication_thread_api | |
is_applier_thread_running() | Replication_thread_api | |
is_applier_thread_stopping() | Replication_thread_api | |
is_applier_thread_waiting() | Replication_thread_api | |
is_own_event_applier(my_thread_id id, const char *channel_name=nullptr) | Replication_thread_api | |
is_own_event_receiver(my_thread_id id) | Replication_thread_api | |
is_partial_transaction_on_relay_log() | Replication_thread_api | |
is_receiver_thread_running() | Replication_thread_api | |
is_receiver_thread_stopping() | Replication_thread_api | |
purge_logs(bool reset_all) | Replication_thread_api | |
queue_packet(const char *buf, ulong event_len) | Replication_thread_api | |
Replication_thread_api(const char *channel_interface) | Replication_thread_api | |
Replication_thread_api() | Replication_thread_api | |
rpl_binlog_dump_thread_kill() | Replication_thread_api | static |
rpl_channel_stop_all(int threads_to_stop, long timeout) | Replication_thread_api | static |
set_channel_name(const char *channel_name) | Replication_thread_api | inline |
set_stop_wait_timeout(ulong timeout) | Replication_thread_api | inline |
start_threads(bool start_receiver, bool start_applier, std::string *view_id, bool wait_for_connection, enum_channel_until_condition until_condition=CHANNEL_UNTIL_VIEW_ID) | Replication_thread_api | |
stop_threads(bool stop_receiver, bool stop_applier) | Replication_thread_api | |
stop_wait_timeout | Replication_thread_api | private |
wait_for_gtid_execution(double timeout) | Replication_thread_api | |
wait_for_gtid_execution(std::string &retrieved_set, double timeout, bool update_THD_status=true) | Replication_thread_api | |
~Replication_thread_api()=default | Replication_thread_api | |