#include <applier.h>
◆ ~Applier_module_interface()
virtual Applier_module_interface::~Applier_module_interface |
( |
| ) |
|
|
inlinevirtual |
◆ add_leaving_members_action_packet()
◆ add_single_primary_action_packet()
◆ add_suspension_packet()
virtual void Applier_module_interface::add_suspension_packet |
( |
| ) |
|
|
pure virtual |
◆ add_sync_before_execution_action_packet()
◆ add_transaction_prepared_action_packet()
◆ add_view_change_packet()
virtual void Applier_module_interface::add_view_change_packet |
( |
View_change_packet * |
packet | ) |
|
|
pure virtual |
◆ awake_applier_module()
virtual void Applier_module_interface::awake_applier_module |
( |
| ) |
|
|
pure virtual |
◆ get_applier_status()
◆ get_certification_handler()
◆ get_flow_control_module()
◆ get_message_queue_size()
virtual size_t Applier_module_interface::get_message_queue_size |
( |
| ) |
|
|
pure virtual |
◆ get_pipeline_stats_member_collector()
◆ get_retrieved_gtid_set()
virtual bool Applier_module_interface::get_retrieved_gtid_set |
( |
std::string & |
retrieved_set | ) |
|
|
pure virtual |
◆ handle()
◆ handle_pipeline_action()
virtual int Applier_module_interface::handle_pipeline_action |
( |
Pipeline_action * |
action | ) |
|
|
pure virtual |
◆ interrupt_applier_suspension_wait()
virtual void Applier_module_interface::interrupt_applier_suspension_wait |
( |
| ) |
|
|
pure virtual |
◆ purge_applier_queue_and_restart_applier_module()
virtual int Applier_module_interface::purge_applier_queue_and_restart_applier_module |
( |
| ) |
|
|
pure virtual |
◆ 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 |
◆ run_flow_control_step()
virtual void Applier_module_interface::run_flow_control_step |
( |
| ) |
|
|
pure virtual |
◆ 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 |
◆ 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 |
◆ 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 |
◆ 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 |
The documentation for this class was generated from the following file: