#include <mysql/group_replication_priv.h>
#include <mysql/plugin_group_replication.h>
#include <list>
#include <vector>
#include "my_inttypes.h"
#include "plugin/group_replication/include/applier_channel_state_observer.h"
#include "plugin/group_replication/include/consistency_manager.h"
#include "plugin/group_replication/include/gcs_operations.h"
#include "plugin/group_replication/include/handlers/applier_handler.h"
#include "plugin/group_replication/include/handlers/certification_handler.h"
#include "plugin/group_replication/include/handlers/pipeline_handlers.h"
#include "plugin/group_replication/include/pipeline_factory.h"
#include "plugin/group_replication/include/pipeline_stats.h"
#include "plugin/group_replication/include/plugin_handlers/stage_monitor_handler.h"
#include "plugin/group_replication/include/plugin_utils.h"
#include "plugin/group_replication/libmysqlgcs/include/mysql/gcs/gcs_member_identifier.h"
#include "sql/sql_class.h"

Classes
class	Action_packet
	A packet to control the applier in a event oriented way. More...

class	Recovery_metadata_processing_packets
	A packet to send Metadata related processing. More...

class	Single_primary_action_packet
	A packet to send new primary election related info to the applier. More...

class	Queue_checkpoint_packet
	A packet to wait for queue consumption. More...

class	Transaction_prepared_action_packet
	A packet to inform that a given member did prepare a given transaction. More...

class	Sync_before_execution_action_packet
	A packet to request a synchronization point on the global message order on a given member before transaction execution. More...

class	Leaving_members_action_packet
	A packet to inform pipeline listeners of leaving members, this packet will be handled on the global message order, that is, ordered with certification. More...

class	Error_action_packet
	A packet to inform the applier it should fail. More...

class	Applier_module_interface

class	Applier_module

Macros
#define	ACTION_PACKET_TYPE 2

#define	SINGLE_PRIMARY_PACKET_TYPE 4

#define	SYNC_BEFORE_EXECUTION_PACKET_TYPE 5

#define	TRANSACTION_PREPARED_PACKET_TYPE 6

#define	LEAVING_MEMBERS_PACKET_TYPE 7

#define	RECOVERY_METADATA_PROCESSING_PACKET_TYPE 8

#define	ERROR_PACKET_TYPE 9
	Make the applier fail. More...

#define	APPLIER_GTID_CHECK_TIMEOUT_ERROR -1

#define	APPLIER_RELAY_LOG_NOT_INITED -2

#define	APPLIER_THREAD_ABORTED -3

Typedefs
typedef enum enum_applier_state	Member_applier_state

Enumerations
enum	enum_packet_action { TERMINATION_PACKET = 0 , SUSPENSION_PACKET , CHECKPOINT_PACKET , ACTION_NUMBER = 3 }

enum	enum_applier_state { APPLIER_STATE_ON = 1 , APPLIER_STATE_OFF , APPLIER_ERROR }

Variables
char	applier_module_channel_name []

Macro Definition Documentation

◆ ACTION_PACKET_TYPE

#define ACTION_PACKET_TYPE 2

◆ APPLIER_GTID_CHECK_TIMEOUT_ERROR

#define APPLIER_GTID_CHECK_TIMEOUT_ERROR -1

◆ APPLIER_RELAY_LOG_NOT_INITED

#define APPLIER_RELAY_LOG_NOT_INITED -2

◆ APPLIER_THREAD_ABORTED

#define APPLIER_THREAD_ABORTED -3

◆ ERROR_PACKET_TYPE

#define ERROR_PACKET_TYPE 9

Make the applier fail.

◆ LEAVING_MEMBERS_PACKET_TYPE

#define LEAVING_MEMBERS_PACKET_TYPE 7

◆ RECOVERY_METADATA_PROCESSING_PACKET_TYPE

#define RECOVERY_METADATA_PROCESSING_PACKET_TYPE 8

◆ SINGLE_PRIMARY_PACKET_TYPE

#define SINGLE_PRIMARY_PACKET_TYPE 4

◆ SYNC_BEFORE_EXECUTION_PACKET_TYPE

#define SYNC_BEFORE_EXECUTION_PACKET_TYPE 5

◆ TRANSACTION_PREPARED_PACKET_TYPE

#define TRANSACTION_PREPARED_PACKET_TYPE 6

Typedef Documentation

◆ Member_applier_state

typedef enum enum_applier_state Member_applier_state

Enumeration Type Documentation

◆ enum_applier_state

enum enum_applier_state

Enumerator
APPLIER_STATE_ON
APPLIER_STATE_OFF
APPLIER_ERROR

◆ enum_packet_action

enum enum_packet_action

Enumerator
TERMINATION_PACKET
SUSPENSION_PACKET
CHECKPOINT_PACKET
ACTION_NUMBER

Variable Documentation

◆ applier_module_channel_name

char applier_module_channel_name[]

extern

Classes

Macros

Typedefs

Enumerations

Variables