Describes all statistics sent by members. More...

#include <pipeline_stats.h>

Inheritance diagram for Pipeline_stats_member_message:

Public Types
enum	enum_payload_item_type { PIT_UNKNOWN = 0 , PIT_TRANSACTIONS_WAITING_CERTIFICATION = 1 , PIT_TRANSACTIONS_WAITING_APPLY = 2 , PIT_TRANSACTIONS_CERTIFIED = 3 , PIT_TRANSACTIONS_APPLIED = 4 , PIT_TRANSACTIONS_LOCAL = 5 , PIT_TRANSACTIONS_NEGATIVE_CERTIFIED = 6 , PIT_TRANSACTIONS_ROWS_VALIDATING = 7 , PIT_TRANSACTIONS_COMMITTED_ALL_MEMBERS = 8 , PIT_TRANSACTION_LAST_CONFLICT_FREE = 9 , PIT_TRANSACTIONS_LOCAL_ROLLBACK = 10 , PIT_FLOW_CONTROL_MODE = 11 , PIT_TRANSACTION_GTIDS_PRESENT = 12 , PIT_SENT_TIMESTAMP = 13 , PIT_MAX = 14 }

Public Types inherited from Plugin_gcs_message
enum	enum_cargo_type { CT_UNKNOWN = 0 , CT_CERTIFICATION_MESSAGE = 1 , CT_TRANSACTION_MESSAGE = 2 , CT_RECOVERY_MESSAGE = 3 , CT_MEMBER_INFO_MESSAGE = 4 , CT_MEMBER_INFO_MANAGER_MESSAGE = 5 , CT_PIPELINE_STATS_MEMBER_MESSAGE = 6 , CT_SINGLE_PRIMARY_MESSAGE = 7 , CT_GROUP_ACTION_MESSAGE = 8 , CT_GROUP_VALIDATION_MESSAGE = 9 , CT_SYNC_BEFORE_EXECUTION_MESSAGE = 10 , CT_TRANSACTION_WITH_GUARANTEE_MESSAGE = 11 , CT_TRANSACTION_PREPARED_MESSAGE = 12 , CT_MESSAGE_SERVICE_MESSAGE = 13 , CT_RECOVERY_METADATA_MESSAGE = 14 , CT_MAX = 15 }
	The different cargo type codes. More...

Public Member Functions
	Pipeline_stats_member_message (int32 transactions_waiting_certification, int32 transactions_waiting_apply, int64 transactions_certified, int64 transactions_applied, int64 transactions_local, int64 transactions_negative_certified, int64 transactions_rows_validating, bool transaction_gtids, const std::string &transactions_committed_all_members, const std::string &transactions_last_conflict_free, int64 transactions_local_rollback, Flow_control_mode mode)
	Message constructor. More...

	Pipeline_stats_member_message (const unsigned char *buf, size_t len)
	Message constructor for raw data. More...

	~Pipeline_stats_member_message () override
	Message destructor. More...

int32	get_transactions_waiting_certification ()
	Get transactions waiting certification counter value. More...

int32	get_transactions_waiting_apply ()
	Get transactions waiting apply counter value. More...

int64	get_transactions_certified ()
	Get transactions certified. More...

int64	get_transactions_applied ()
	Get transactions applied. More...

int64	get_transactions_local ()
	Get local transactions that member tried to commit. More...

int64	get_transactions_negative_certified ()
	Get negatively certified transaction by member. More...

int64	get_transactions_rows_validating ()
	Get size of conflict detection database. More...

bool	get_transation_gtids_present () const
	Returns a flag indicating whether or not the GTIDs on this stats message are updated/present. More...

const std::string &	get_transaction_committed_all_members ()
	Get set of stable group transactions. More...

const std::string &	get_transaction_last_conflict_free ()
	Get last positive certified transaction. More...

int64	get_transactions_local_rollback ()
	Get local transactions rolled back by the member. More...

Flow_control_mode	get_flow_control_mode ()
	Get flow-control mode of member. More...

Public Member Functions inherited from Plugin_gcs_message
virtual	~Plugin_gcs_message ()=default

int	get_version ()

unsigned short	get_header_length ()

enum_cargo_type	get_cargo_type () const

unsigned long long	get_msg_length ()

void	encode (std::vector< unsigned char > *buffer) const
	Encodes the contents of this instance into the buffer. More...

void	decode (const unsigned char *buffer, size_t length)
	Decodes the contents of the buffer and sets the field values according to the values decoded. More...

Static Public Member Functions
static uint64_t	get_sent_timestamp (const unsigned char *buffer, size_t length)
	Return the time at which the message contained in the buffer was sent. More...

Static Public Member Functions inherited from Plugin_gcs_message
static enum_cargo_type	get_cargo_type (const unsigned char *buffer)
	Return the cargo type of a given message buffer, without decode the complete message. More...

static void	get_first_payload_item_raw_data (const unsigned char buffer, const unsigned char payload_item_data, size_t payload_item_length)
	Return the raw data of the first payload item of a given message buffer, without decode the complete message. More...

static bool	get_payload_item_type_raw_data (const unsigned char buffer, const unsigned char end, uint16 payload_item_type, const unsigned char *payload_item_data, unsigned long long payload_item_length)
	Return the raw data of the payload item of a given payload type of a given message buffer. More...

Protected Member Functions
void	encode_payload (std::vector< unsigned char > *buffer) const override
	Encodes the message contents for transmission. More...

void	decode_payload (const unsigned char buffer, const unsigned char end) override
	Message decoding method. More...

Protected Member Functions inherited from Plugin_gcs_message
	Plugin_gcs_message (enum_cargo_type cargo_type)
	Plugin_gcs_message constructor. More...

void	encode_header (std::vector< unsigned char > *buffer) const
	Encodes the header of this instance into the buffer. More...

void	decode_header (const unsigned char **slider)
	Decodes the header of the buffer into this instance. More...

void	encode_payload_item_type_and_length (std::vector< unsigned char > *buffer, uint16 payload_item_type, unsigned long long payload_item_length) const
	Encodes the given payload item type and length into the buffer. More...

void	encode_payload_item_char (std::vector< unsigned char > *buffer, uint16 type, unsigned char value) const
	Encodes the given payload item (type, length and value) into the buffer as a char (1 byte). More...

void	encode_payload_item_int2 (std::vector< unsigned char > *buffer, uint16 type, uint16 value) const
	Encodes the given payload item (type, length and value) into the buffer as a 2 bytes integer. More...

void	decode_payload_item_int2 (const unsigned char *buffer, uint16 type, uint16 *value)
	Decodes the given payload item (type, length and value) from the buffer as a 2 bytes integer. More...

void	encode_payload_item_int4 (std::vector< unsigned char > *buffer, uint16 type, uint32 value) const
	Encodes the given payload item (type, length and value) into the buffer as a 4 bytes integer. More...

void	decode_payload_item_int4 (const unsigned char *buffer, uint16 type, uint32 *value)
	Decodes the given payload item (type, length and value) from the buffer as a 4 bytes integer. More...

void	encode_payload_item_int8 (std::vector< unsigned char > *buffer, uint16 type, ulonglong value) const
	Encodes the given payload item (type, length and value) into the buffer as a 8 bytes integer. More...

void	encode_payload_item_string (std::vector< unsigned char > buffer, uint16 type, const char value, unsigned long long length) const
	Encodes the given payload item (type, length and value) into the buffer as a char array (variable size). More...

void	decode_payload_item_string (const unsigned char *buffer, uint16 type, std::string value, unsigned long long length)
	Decodes the given payload item (type, length and value) from the buffer as a char array (variable size). More...

void	encode_payload_item_bytes (std::vector< unsigned char > buffer, uint16 type, const unsigned char value, unsigned long long length) const
	Encodes the given payload item (type, length and value) into the buffer as a byte buffer (variable size). More...

void	decode_payload_item_bytes (const unsigned char *buffer, uint16 type, unsigned char value, unsigned long long length)
	Decodes the given payload item (type, length and value) from the buffer as a byte buffer (variable size). More...

Additional Inherited Members
Static Public Attributes inherited from Plugin_gcs_message
static const int	PLUGIN_GCS_MESSAGE_VERSION = 1
	The protocol version number. More...

static const unsigned int	WIRE_VERSION_SIZE = 4
	The protocol version number. More...

static const unsigned int	WIRE_HD_LEN_SIZE = 2
	The on-the-wire size of the header length field. More...

static const unsigned int	WIRE_MSG_LEN_SIZE = 8
	The on-the-wire size of the message size field. More...

static const unsigned int	WIRE_CARGO_TYPE_SIZE = 2
	The on-the-wire size of the cargo type field. More...

static const unsigned int	WIRE_FIXED_HEADER_SIZE
	The on-the-wire size of the fixed header. More...

static const unsigned int	WIRE_PAYLOAD_ITEM_TYPE_SIZE = 2
	The on-the-wire size of the each payload item type field. More...

static const unsigned int	WIRE_PAYLOAD_ITEM_LEN_SIZE = 8
	The on-the-wire size of the each payload item size field. More...

static const unsigned int	WIRE_PAYLOAD_ITEM_HEADER_SIZE
	The on-the-wire size of the payload item header. More...

Static Protected Member Functions inherited from Plugin_gcs_message
static int64_t	get_sent_timestamp (const unsigned char *buffer, size_t length, const uint16 timestamp_payload_item_type)
	Return the time at which the message contained in the buffer was sent. More...

static void	decode_payload_item_type_and_length (const unsigned char *buffer, uint16 payload_item_type, unsigned long long *payload_item_length)
	Decodes the given payload item type and length from the buffer. More...

static void	decode_payload_item_char (const unsigned char *buffer, uint16 type, unsigned char *value)
	Decodes the given payload item (type, length and value) from the buffer as a char (1 byte). More...

static void	decode_payload_item_int8 (const unsigned char *buffer, uint16 type, uint64 *value)
	Decodes the given payload item (type, length and value) from the buffer as a 8 bytes integer. More...

Detailed Description

Describes all statistics sent by members.

Member Enumeration Documentation

◆ enum_payload_item_type

enum Pipeline_stats_member_message::enum_payload_item_type

Enumerator
PIT_UNKNOWN
PIT_TRANSACTIONS_WAITING_CERTIFICATION
PIT_TRANSACTIONS_WAITING_APPLY
PIT_TRANSACTIONS_CERTIFIED
PIT_TRANSACTIONS_APPLIED
PIT_TRANSACTIONS_LOCAL
PIT_TRANSACTIONS_NEGATIVE_CERTIFIED
PIT_TRANSACTIONS_ROWS_VALIDATING
PIT_TRANSACTIONS_COMMITTED_ALL_MEMBERS
PIT_TRANSACTION_LAST_CONFLICT_FREE
PIT_TRANSACTIONS_LOCAL_ROLLBACK
PIT_FLOW_CONTROL_MODE
PIT_TRANSACTION_GTIDS_PRESENT
PIT_SENT_TIMESTAMP
PIT_MAX

Constructor & Destructor Documentation

◆ Pipeline_stats_member_message() [1/2]

Pipeline_stats_member_message::Pipeline_stats_member_message	(	int32	transactions_waiting_certification,
		int32	transactions_waiting_apply,
		int64	transactions_certified,
		int64	transactions_applied,
		int64	transactions_local,
		int64	transactions_negative_certified,
		int64	transactions_rows_validating,
		bool	transaction_gtids,
		const std::string &	transactions_committed_all_members,
		const std::string &	transactions_last_conflict_free,
		int64	transactions_local_rollback,
		Flow_control_mode	mode
	)

Message constructor.

Parameters

[in]	transactions_waiting_certification	Number of transactions pending certification
[in]	transactions_waiting_apply	Number of remote transactions waiting apply
[in]	transactions_certified	Number of transactions already certified
[in]	transactions_applied	Number of remote transactions applied
[in]	transactions_local	Number of local transactions
[in]	transactions_negative_certified	Number of transactions that were negatively certified
[in]	transactions_rows_validating	Number of transactions with which certification will be done against
[in]	transaction_gtids	Flag to indicate whether or not the transaction ids have been updated
[in]	transactions_committed_all_members	Set of transactions committed on all members
[in]	transactions_last_conflict_free	Latest transaction certified without conflicts
[in]	transactions_local_rollback	Number of local transactions that were negatively certified
[in]	mode	Flow-control mode

◆ Pipeline_stats_member_message() [2/2]

Pipeline_stats_member_message::Pipeline_stats_member_message	(	const unsigned char *	buf,
		size_t	len
	)

Message constructor for raw data.

Parameters

[in]	buf	raw data
[in]	len	raw length

◆ ~Pipeline_stats_member_message()

Pipeline_stats_member_message::~Pipeline_stats_member_message ( )

overridedefault

Message destructor.

Member Function Documentation

◆ decode_payload()

void Pipeline_stats_member_message::decode_payload	(	const unsigned char *	buffer,
		const unsigned char *	end
	)

overrideprotectedvirtual

Message decoding method.

Parameters

[in]	buffer	the received data
[in]	end	the end of the buffer

Implements Plugin_gcs_message.

◆ encode_payload()

void Pipeline_stats_member_message::encode_payload ( std::vector< unsigned char > * buffer ) const

overrideprotectedvirtual

Encodes the message contents for transmission.

Parameters

[out] buffer the message buffer to be written

Implements Plugin_gcs_message.

◆ get_flow_control_mode()

Flow_control_mode Pipeline_stats_member_message::get_flow_control_mode ( )

Get flow-control mode of member.

Returns: the mode value

◆ get_sent_timestamp()

uint64_t Pipeline_stats_member_message::get_sent_timestamp	(	const unsigned char *	buffer,
		size_t	length
	)

static

Return the time at which the message contained in the buffer was sent.

See also: Metrics_handler::get_current_time()

Parameters

[in]	buffer	the buffer to decode from.
[in]	length	the buffer length

Returns: the time on which the message was sent.

◆ get_transaction_committed_all_members()

const std::string & Pipeline_stats_member_message::get_transaction_committed_all_members ( )

Get set of stable group transactions.

Returns: the transaction identifier.

◆ get_transaction_last_conflict_free()

const std::string & Pipeline_stats_member_message::get_transaction_last_conflict_free ( )

Get last positive certified transaction.

Returns: the transaction identifier.

◆ get_transactions_applied()

int64 Pipeline_stats_member_message::get_transactions_applied ( )

Get transactions applied.

Returns: the counter value

◆ get_transactions_certified()

int64 Pipeline_stats_member_message::get_transactions_certified ( )

Get transactions certified.

Returns: the counter value

◆ get_transactions_local()

int64 Pipeline_stats_member_message::get_transactions_local ( )

Get local transactions that member tried to commit.

Returns: the counter value

◆ get_transactions_local_rollback()

int64 Pipeline_stats_member_message::get_transactions_local_rollback ( )

Get local transactions rolled back by the member.

Returns: the transaction identifiers.

◆ get_transactions_negative_certified()

int64 Pipeline_stats_member_message::get_transactions_negative_certified ( )

Get negatively certified transaction by member.

Returns: the counter value

◆ get_transactions_rows_validating()

int64 Pipeline_stats_member_message::get_transactions_rows_validating ( )

Get size of conflict detection database.

Returns: the counter value

◆ get_transactions_waiting_apply()

int32 Pipeline_stats_member_message::get_transactions_waiting_apply ( )

Get transactions waiting apply counter value.

Returns: the counter value

◆ get_transactions_waiting_certification()

int32 Pipeline_stats_member_message::get_transactions_waiting_certification ( )

Get transactions waiting certification counter value.

Returns: the counter value

◆ get_transation_gtids_present()

bool Pipeline_stats_member_message::get_transation_gtids_present ( ) const

Returns a flag indicating whether or not the GTIDs on this stats message are updated/present.

Returns: the flag indicating the presence of valid GTIDs on this message.

Member Data Documentation

◆ m_flow_control_mode

Flow_control_mode Pipeline_stats_member_message::m_flow_control_mode

private

◆ m_transaction_gtids_present

bool Pipeline_stats_member_message::m_transaction_gtids_present

private

◆ m_transaction_last_conflict_free

std::string Pipeline_stats_member_message::m_transaction_last_conflict_free

private

◆ m_transactions_applied

int64 Pipeline_stats_member_message::m_transactions_applied

private

◆ m_transactions_certified

int64 Pipeline_stats_member_message::m_transactions_certified

private

◆ m_transactions_committed_all_members

std::string Pipeline_stats_member_message::m_transactions_committed_all_members

private

◆ m_transactions_local

int64 Pipeline_stats_member_message::m_transactions_local

private

◆ m_transactions_local_rollback

int64 Pipeline_stats_member_message::m_transactions_local_rollback

private

◆ m_transactions_negative_certified

int64 Pipeline_stats_member_message::m_transactions_negative_certified

private

◆ m_transactions_rows_validating

int64 Pipeline_stats_member_message::m_transactions_rows_validating

private

◆ m_transactions_waiting_apply

int32 Pipeline_stats_member_message::m_transactions_waiting_apply

private

◆ m_transactions_waiting_certification

int32 Pipeline_stats_member_message::m_transactions_waiting_certification

private

The documentation for this class was generated from the following files:

plugin/group_replication/include/pipeline_stats.h
plugin/group_replication/src/pipeline_stats.cc

Private Attributes
int32	m_transactions_waiting_certification

int32	m_transactions_waiting_apply

int64	m_transactions_certified

int64	m_transactions_applied

int64	m_transactions_local

int64	m_transactions_negative_certified

int64	m_transactions_rows_validating

bool	m_transaction_gtids_present

std::string	m_transactions_committed_all_members

std::string	m_transaction_last_conflict_free

int64	m_transactions_local_rollback

Flow_control_mode	m_flow_control_mode

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Enumeration Documentation

◆ enum_payload_item_type

Constructor & Destructor Documentation

◆ Pipeline_stats_member_message() [1/2]

◆ Pipeline_stats_member_message() [2/2]

◆ ~Pipeline_stats_member_message()

Member Function Documentation

◆ decode_payload()

◆ encode_payload()

◆ get_flow_control_mode()

◆ get_sent_timestamp()

◆ get_transaction_committed_all_members()

◆ get_transaction_last_conflict_free()

◆ get_transactions_applied()

◆ get_transactions_certified()

◆ get_transactions_local()

◆ get_transactions_local_rollback()

◆ get_transactions_negative_certified()

◆ get_transactions_rows_validating()

◆ get_transactions_waiting_apply()

◆ get_transactions_waiting_certification()

◆ get_transation_gtids_present()

Member Data Documentation

◆ m_flow_control_mode

◆ m_transaction_gtids_present

◆ m_transaction_last_conflict_free

◆ m_transactions_applied

◆ m_transactions_certified

◆ m_transactions_committed_all_members

◆ m_transactions_local

◆ m_transactions_local_rollback

◆ m_transactions_negative_certified

◆ m_transactions_rows_validating

◆ m_transactions_waiting_apply

◆ m_transactions_waiting_certification