#include <applier.h>

Inheritance diagram for Applier_module_interface:

Public Member Functions
virtual	~Applier_module_interface ()=default

virtual Certification_handler *	get_certification_handler ()=0

virtual int	wait_for_applier_complete_suspension (bool *abort_flag, bool wait_for_execution=true)=0

virtual void	awake_applier_module ()=0

virtual void	interrupt_applier_suspension_wait ()=0

virtual int	wait_for_applier_event_execution (double timeout, bool check_and_purge_partial_transactions)=0

virtual bool	wait_for_current_events_execution (std::shared_ptr< Continuation > checkpoint_condition, bool *abort_flag, bool update_THD_status=true)=0

virtual bool	get_retrieved_gtid_set (std::string &retrieved_set)=0

virtual int	wait_for_applier_event_execution (std::string &retrieved_set, double timeout, bool update_THD_status=true)=0

virtual size_t	get_message_queue_size ()=0

virtual Member_applier_state	get_applier_status ()=0

virtual void	add_suspension_packet ()=0

virtual void	add_packet (Packet *packet)=0

virtual void	add_view_change_packet (View_change_packet *packet)=0

virtual void	add_metadata_processing_packet (Recovery_metadata_processing_packets *packet)=0

virtual void	add_single_primary_action_packet (Single_primary_action_packet *packet)=0

virtual void	add_transaction_prepared_action_packet (Transaction_prepared_action_packet *packet)=0

virtual void	add_sync_before_execution_action_packet (Sync_before_execution_action_packet *packet)=0

virtual void	add_leaving_members_action_packet (Leaving_members_action_packet *packet)=0

virtual int	handle (const uchar data, ulong len, enum_group_replication_consistency_level consistency_level, std::list< Gcs_member_identifier > online_members, PSI_memory_key key)=0

virtual int	handle_pipeline_action (Pipeline_action *action)=0

virtual Flow_control_module *	get_flow_control_module ()=0

virtual void	run_flow_control_step ()=0

virtual int	purge_applier_queue_and_restart_applier_module ()=0

virtual bool	queue_and_wait_on_queue_checkpoint (std::shared_ptr< Continuation > checkpoint_condition)=0

virtual Pipeline_stats_member_collector *	get_pipeline_stats_member_collector ()=0

Constructor & Destructor Documentation

◆ ~Applier_module_interface()

virtual Applier_module_interface::~Applier_module_interface ( )

virtualdefault

Member Function Documentation

◆ add_leaving_members_action_packet()

virtual void Applier_module_interface::add_leaving_members_action_packet ( Leaving_members_action_packet * packet )

pure virtual

Implemented in Applier_module.

◆ add_metadata_processing_packet()

virtual void Applier_module_interface::add_metadata_processing_packet ( Recovery_metadata_processing_packets * packet )

pure virtual

Implemented in Applier_module.

◆ add_packet()

virtual void Applier_module_interface::add_packet ( Packet * packet )

pure virtual

Implemented in Applier_module.

◆ add_single_primary_action_packet()

virtual void Applier_module_interface::add_single_primary_action_packet ( Single_primary_action_packet * packet )

pure virtual

Implemented in Applier_module.

◆ add_suspension_packet()

virtual void Applier_module_interface::add_suspension_packet ( )

pure virtual

Implemented in Applier_module.

◆ add_sync_before_execution_action_packet()

virtual void Applier_module_interface::add_sync_before_execution_action_packet ( Sync_before_execution_action_packet * packet )

pure virtual

Implemented in Applier_module.

◆ add_transaction_prepared_action_packet()

virtual void Applier_module_interface::add_transaction_prepared_action_packet ( Transaction_prepared_action_packet * packet )

pure virtual

Implemented in Applier_module.

◆ add_view_change_packet()

virtual void Applier_module_interface::add_view_change_packet ( View_change_packet * packet )

pure virtual

Implemented in Applier_module.

◆ awake_applier_module()

virtual void Applier_module_interface::awake_applier_module ( )

pure virtual

Implemented in Applier_module.

◆ get_applier_status()

virtual Member_applier_state Applier_module_interface::get_applier_status ( )

pure virtual

Implemented in Applier_module.

◆ get_certification_handler()

virtual Certification_handler * Applier_module_interface::get_certification_handler ( )

pure virtual

Implemented in Applier_module.

◆ get_flow_control_module()

virtual Flow_control_module * Applier_module_interface::get_flow_control_module ( )

pure virtual

Implemented in Applier_module.

◆ get_message_queue_size()

virtual size_t Applier_module_interface::get_message_queue_size ( )

pure virtual

Implemented in Applier_module.

◆ get_pipeline_stats_member_collector()

virtual Pipeline_stats_member_collector * Applier_module_interface::get_pipeline_stats_member_collector ( )

pure virtual

Implemented in Applier_module.

◆ get_retrieved_gtid_set()

virtual bool Applier_module_interface::get_retrieved_gtid_set ( std::string & retrieved_set )

pure virtual

Implemented in Applier_module.

◆ handle()

virtual int Applier_module_interface::handle	(	const uchar *	data,
		ulong	len,
		enum_group_replication_consistency_level	consistency_level,
		std::list< Gcs_member_identifier > *	online_members,
		PSI_memory_key	key
	)

pure virtual

Implemented in Applier_module.

◆ handle_pipeline_action()

virtual int Applier_module_interface::handle_pipeline_action ( Pipeline_action * action )

pure virtual

Implemented in Applier_module.

◆ interrupt_applier_suspension_wait()

virtual void Applier_module_interface::interrupt_applier_suspension_wait ( )

pure virtual

Implemented in Applier_module.

◆ purge_applier_queue_and_restart_applier_module()

virtual int Applier_module_interface::purge_applier_queue_and_restart_applier_module ( )

pure virtual

Implemented in Applier_module.

◆ queue_and_wait_on_queue_checkpoint()

virtual bool Applier_module_interface::queue_and_wait_on_queue_checkpoint ( std::shared_ptr< Continuation > checkpoint_condition )

pure virtual

Implemented in Applier_module.

◆ run_flow_control_step()

virtual void Applier_module_interface::run_flow_control_step ( )

pure virtual

Implemented in Applier_module.

◆ wait_for_applier_complete_suspension()

virtual int Applier_module_interface::wait_for_applier_complete_suspension	(	bool *	abort_flag,
		bool	wait_for_execution = `true`
	)

pure virtual

Implemented in Applier_module.

◆ wait_for_applier_event_execution() [1/2]

virtual int Applier_module_interface::wait_for_applier_event_execution	(	double	timeout,
		bool	check_and_purge_partial_transactions
	)

pure virtual

Implemented in Applier_module.

◆ wait_for_applier_event_execution() [2/2]

virtual int Applier_module_interface::wait_for_applier_event_execution	(	std::string &	retrieved_set,
		double	timeout,
		bool	update_THD_status = `true`
	)

pure virtual

Implemented in Applier_module.

◆ wait_for_current_events_execution()

virtual bool Applier_module_interface::wait_for_current_events_execution	(	std::shared_ptr< Continuation >	checkpoint_condition,
		bool *	abort_flag,
		bool	update_THD_status = `true`
	)

pure virtual

Implemented in Applier_module.

The documentation for this class was generated from the following file:

plugin/group_replication/include/applier.h

Public Member Functions

Constructor & Destructor Documentation

◆ ~Applier_module_interface()

Member Function Documentation

◆ add_leaving_members_action_packet()

◆ add_metadata_processing_packet()

◆ add_packet()

◆ add_single_primary_action_packet()

◆ add_suspension_packet()

◆ add_sync_before_execution_action_packet()

◆ add_transaction_prepared_action_packet()

◆ add_view_change_packet()

◆ awake_applier_module()

◆ get_applier_status()

◆ get_certification_handler()

◆ get_flow_control_module()

◆ get_message_queue_size()

◆ get_pipeline_stats_member_collector()

◆ get_retrieved_gtid_set()

◆ handle()

◆ handle_pipeline_action()

◆ interrupt_applier_suspension_wait()

◆ purge_applier_queue_and_restart_applier_module()

◆ queue_and_wait_on_queue_checkpoint()

◆ run_flow_control_step()

◆ wait_for_applier_complete_suspension()

◆ wait_for_applier_event_execution() [1/2]

◆ wait_for_applier_event_execution() [2/2]

◆ wait_for_current_events_execution()