add_leaving_members_action_packet(Leaving_members_action_packet *packet)=0 | Applier_module_interface | pure virtual |
add_metadata_processing_packet(Recovery_metadata_processing_packets *packet)=0 | Applier_module_interface | pure virtual |
add_packet(Packet *packet)=0 | Applier_module_interface | pure virtual |
add_single_primary_action_packet(Single_primary_action_packet *packet)=0 | Applier_module_interface | pure virtual |
add_suspension_packet()=0 | Applier_module_interface | pure virtual |
add_sync_before_execution_action_packet(Sync_before_execution_action_packet *packet)=0 | Applier_module_interface | pure virtual |
add_transaction_prepared_action_packet(Transaction_prepared_action_packet *packet)=0 | Applier_module_interface | pure virtual |
add_view_change_packet(View_change_packet *packet)=0 | Applier_module_interface | pure virtual |
awake_applier_module()=0 | Applier_module_interface | pure virtual |
get_applier_status()=0 | Applier_module_interface | pure virtual |
get_certification_handler()=0 | Applier_module_interface | pure virtual |
get_flow_control_module()=0 | Applier_module_interface | pure virtual |
get_message_queue_size()=0 | Applier_module_interface | pure virtual |
get_pipeline_stats_member_collector()=0 | Applier_module_interface | pure virtual |
get_retrieved_gtid_set(std::string &retrieved_set)=0 | Applier_module_interface | pure virtual |
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 | Applier_module_interface | pure virtual |
handle_pipeline_action(Pipeline_action *action)=0 | Applier_module_interface | pure virtual |
interrupt_applier_suspension_wait()=0 | Applier_module_interface | pure virtual |
purge_applier_queue_and_restart_applier_module()=0 | Applier_module_interface | pure virtual |
queue_and_wait_on_queue_checkpoint(std::shared_ptr< Continuation > checkpoint_condition)=0 | Applier_module_interface | pure virtual |
run_flow_control_step()=0 | Applier_module_interface | pure virtual |
wait_for_applier_complete_suspension(bool *abort_flag, bool wait_for_execution=true)=0 | Applier_module_interface | pure virtual |
wait_for_applier_event_execution(double timeout, bool check_and_purge_partial_transactions)=0 | Applier_module_interface | pure virtual |
wait_for_applier_event_execution(std::string &retrieved_set, double timeout, bool update_THD_status=true)=0 | Applier_module_interface | pure virtual |
wait_for_current_events_execution(std::shared_ptr< Continuation > checkpoint_condition, bool *abort_flag, bool update_THD_status=true)=0 | Applier_module_interface | pure virtual |
~Applier_module_interface()=default | Applier_module_interface | virtual |