MySQL 8.3.0
Source Code Documentation
Applier_module_interface Class Referenceabstract

#include <applier.h>

Inheritance diagram for Applier_module_interface:
[legend]

Public Member Functions

virtual ~Applier_module_interface ()=default
 
virtual Certification_handlerget_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_moduleget_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_collectorget_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: