MySQL  8.0.19
Source Code Documentation
Applier_module Member List

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

add_leaving_members_action_packet(Leaving_members_action_packet *packet)Applier_moduleinlinevirtual
add_single_primary_action_packet(Single_primary_action_packet *packet)Applier_moduleinlinevirtual
add_suspension_packet()Applier_moduleinlinevirtual
add_sync_before_execution_action_packet(Sync_before_execution_action_packet *packet)Applier_moduleinlinevirtual
add_termination_packet()Applier_moduleinline
add_transaction_prepared_action_packet(Transaction_prepared_action_packet *packet)Applier_moduleinlinevirtual
add_view_change_packet(View_change_packet *packet)Applier_moduleinlinevirtual
applier_abortedApplier_moduleprivate
applier_channel_observerApplier_moduleprivate
applier_errorApplier_moduleprivate
applier_killed_statusApplier_moduleprivate
Applier_module()Applier_module
applier_pthdApplier_moduleprivate
applier_thdApplier_moduleprivate
applier_thd_stateApplier_moduleprivate
applier_thread_handle()Applier_module
apply_action_packet(Action_packet *action_packet)Applier_moduleprivate
apply_data_packet(Data_packet *data_packet, Format_description_log_event *fde_evt, Continuation *cont)Applier_moduleprivate
apply_leaving_members_action_packet(Leaving_members_action_packet *packet)Applier_moduleprivate
apply_single_primary_action_packet(Single_primary_action_packet *packet)Applier_moduleprivate
apply_sync_before_execution_action_packet(Sync_before_execution_action_packet *packet)Applier_moduleprivate
apply_transaction_prepared_action_packet(Transaction_prepared_action_packet *packet)Applier_moduleprivate
apply_view_change_packet(View_change_packet *view_change_packet, Format_description_log_event *fde_evt, Continuation *cont)Applier_moduleprivate
awake_applier_module()Applier_moduleinlinevirtual
clean_applier_thread_context()Applier_moduleprivate
flow_control_moduleApplier_moduleprivate
get_applier_status()Applier_moduleinlinevirtual
get_certification_handler()Applier_modulevirtual
get_flow_control_module()Applier_moduleinlinevirtual
get_message_queue_size()Applier_moduleinlinevirtual
get_pipeline_stats_member_collector()Applier_moduleinlinevirtual
get_retrieved_gtid_set(std::string &retrieved_set)Applier_modulevirtual
group_replication_sidnoApplier_moduleprivate
gtid_assignment_block_sizeApplier_moduleprivate
handle(const uchar *data, ulong len, enum_group_replication_consistency_level consistency_level, std::list< Gcs_member_identifier > *online_members)Applier_moduleinlinevirtual
handle_pipeline_action(Pipeline_action *action)Applier_moduleinlinevirtual
incomingApplier_moduleprivate
inform_of_applier_stop(char *channel_name, bool aborted)Applier_module
initialize_applier_thread()Applier_module
inject_event_into_pipeline(Pipeline_event *pevent, Continuation *cont)Applier_module
interrupt_applier_suspension_wait()Applier_modulevirtual
intersect_group_executed_sets(std::vector< std::string > &gtid_sets, Gtid_set *output_set)Applier_moduleprivate
is_applier_thread_aborted()Applier_moduleinline
is_applier_thread_waiting()Applier_module
is_running()Applier_moduleinline
pipelineApplier_moduleprivate
pipeline_stats_member_collectorApplier_moduleprivate
purge_applier_queue_and_restart_applier_module()Applier_modulevirtual
queue_and_wait_on_queue_checkpoint(std::shared_ptr< Continuation > checkpoint_condition)Applier_modulevirtual
queue_certification_enabling_packet()Applier_modulevirtual
reset_applier_logsApplier_moduleprivate
run_condApplier_moduleprivate
run_flow_control_step()Applier_moduleinlinevirtual
run_lockApplier_moduleprivate
set_applier_thread_context()Applier_moduleprivate
set_stop_wait_timeout(ulong timeout)Applier_moduleinline
setup_applier_module(Handler_pipeline_type pipeline_type, bool reset_logs, ulong stop_timeout, rpl_sidno group_sidno, ulonglong gtid_assignment_block_size, Shared_writelock *shared_stop_lock)Applier_module
setup_pipeline_handlers()Applier_module
shared_stop_write_lockApplier_moduleprivate
stage_handlerApplier_moduleprivate
stop_wait_timeoutApplier_moduleprivate
suspend_applier_module()Applier_moduleinlineprivate
suspend_condApplier_moduleprivate
suspend_lockApplier_moduleprivate
suspendedApplier_moduleprivate
suspension_waiting_conditionApplier_moduleprivate
terminate_applier_pipeline()Applier_module
terminate_applier_thread()Applier_module
wait_for_applier_complete_suspension(bool *abort_flag, bool wait_for_execution=true)Applier_modulevirtual
wait_for_applier_event_execution(double timeout, bool check_and_purge_partial_transactions)Applier_modulevirtual
wait_for_applier_event_execution(std::string &retrieved_set, double timeout, bool update_THD_status=true)Applier_modulevirtual
wait_for_current_events_execution(std::shared_ptr< Continuation > checkpoint_condition, bool *abort_flag, bool update_THD_status=true)Applier_modulevirtual
waiting_for_applier_suspensionApplier_moduleprivate
~Applier_module()Applier_module
~Applier_module_interface()Applier_module_interfaceinlinevirtual