Applier_module_interface Class Reference

#include <applier.h>

Inheritance diagram for Applier_module_interface:

Public Member Functions
virtual	~Applier_module_interface ()
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_view_change_packet (View_change_packet *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)=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 ( )

inlinevirtual

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_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  )

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