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) override	Applier_module	inlinevirtual
add_metadata_processing_packet(Recovery_metadata_processing_packets *packet) override	Applier_module	inlinevirtual
add_packet(Packet *packet) override	Applier_module	inlinevirtual
add_single_primary_action_packet(Single_primary_action_packet *packet) override	Applier_module	inlinevirtual
add_suspension_packet() override	Applier_module	inlinevirtual
add_sync_before_execution_action_packet(Sync_before_execution_action_packet *packet) override	Applier_module	inlinevirtual
add_termination_packet()	Applier_module	inline
add_transaction_prepared_action_packet(Transaction_prepared_action_packet *packet) override	Applier_module	inlinevirtual
add_view_change_packet(View_change_packet *packet) override	Applier_module	inlinevirtual
applier_aborted	Applier_module	private
applier_channel_observer	Applier_module	private
applier_error	Applier_module	private
applier_killed_status	Applier_module	private
Applier_module()	Applier_module
applier_pthd	Applier_module	private
applier_thd	Applier_module	private
applier_thd_state	Applier_module	private
applier_thread_handle()	Applier_module
apply_action_packet(Action_packet *action_packet)	Applier_module	private
apply_data_packet(Data_packet *data_packet, Format_description_log_event *fde_evt, Continuation *cont)	Applier_module	private
apply_leaving_members_action_packet(Leaving_members_action_packet *packet)	Applier_module	private
apply_metadata_processing_packet(Recovery_metadata_processing_packets *metadata_processing_packet)	Applier_module	private
apply_single_primary_action_packet(Single_primary_action_packet *packet)	Applier_module	private
apply_sync_before_execution_action_packet(Sync_before_execution_action_packet *packet)	Applier_module	private
apply_transaction_prepared_action_packet(Transaction_prepared_action_packet *packet)	Applier_module	private
apply_view_change_packet(View_change_packet *view_change_packet, Format_description_log_event *fde_evt, Continuation *cont)	Applier_module	private
awake_applier_module() override	Applier_module	inlinevirtual
clean_applier_thread_context()	Applier_module	private
flow_control_module	Applier_module	private
get_applier_status() override	Applier_module	inlinevirtual
get_certification_handler() override	Applier_module	virtual
get_flow_control_module() override	Applier_module	inlinevirtual
get_local_pipeline_stats()	Applier_module
get_message_queue_size() override	Applier_module	inlinevirtual
get_pipeline_stats_member_collector() override	Applier_module	inlinevirtual
get_retrieved_gtid_set(std::string &retrieved_set) override	Applier_module	virtual
group_replication_sidno	Applier_module	private
gtid_assignment_block_size	Applier_module	private
handle(const uchar *data, ulong len, enum_group_replication_consistency_level consistency_level, std::list< Gcs_member_identifier > *online_members, PSI_memory_key key) override	Applier_module	inlinevirtual
handle_pipeline_action(Pipeline_action *action) override	Applier_module	inlinevirtual
ignore_errors_during_stop(bool ignore_errors)	Applier_module	inline
incoming	Applier_module	private
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() override	Applier_module	virtual
intersect_group_executed_sets(std::vector< std::string > &gtid_sets, Gtid_set *output_set)	Applier_module	private
is_applier_thread_aborted()	Applier_module	inline
is_applier_thread_waiting()	Applier_module
is_running()	Applier_module	inline
m_ignore_applier_errors_during_stop	Applier_module	private
pipeline	Applier_module	private
pipeline_stats_member_collector	Applier_module	private
purge_applier_queue_and_restart_applier_module() override	Applier_module	virtual
queue_and_wait_on_queue_checkpoint(std::shared_ptr< Continuation > checkpoint_condition) override	Applier_module	virtual
queue_certification_enabling_packet()	Applier_module	virtual
reset_applier_logs	Applier_module	private
run_cond	Applier_module	private
run_flow_control_step() override	Applier_module	inlinevirtual
run_lock	Applier_module	private
set_applier_thread_context()	Applier_module	private
set_stop_wait_timeout(ulong timeout)	Applier_module	inline
setup_applier_module(Handler_pipeline_type pipeline_type, bool reset_logs, ulong stop_timeout, rpl_sidno group_sidno, ulonglong gtid_assignment_block_size)	Applier_module
setup_pipeline_handlers()	Applier_module
stage_handler	Applier_module	private
stop_wait_timeout	Applier_module	private
suspend_applier_module()	Applier_module	inlineprivate
suspend_cond	Applier_module	private
suspend_lock	Applier_module	private
suspended	Applier_module	private
suspension_waiting_condition	Applier_module	private
terminate_applier_pipeline()	Applier_module
terminate_applier_thread()	Applier_module
wait_for_applier_complete_suspension(bool *abort_flag, bool wait_for_execution=true) override	Applier_module	virtual
wait_for_applier_event_execution(double timeout, bool check_and_purge_partial_transactions) override	Applier_module	virtual
wait_for_applier_event_execution(std::string &retrieved_set, double timeout, bool update_THD_status=true) override	Applier_module	virtual
wait_for_current_events_execution(std::shared_ptr< Continuation > checkpoint_condition, bool *abort_flag, bool update_THD_status=true) override	Applier_module	virtual
~Applier_module() override	Applier_module
~Applier_module_interface()=default	Applier_module_interface	virtual