#include <metrics_handler.h>

Public Types
enum class	enum_message_type { CONTROL , DATA }

Public Member Functions
	Metrics_handler ()=default

virtual	~Metrics_handler ()=default

void	reset ()
	Reset the metrics. More...

uint64_t	get_control_messages_sent_count () const
	Number of control messages sent by this member. More...

uint64_t	get_data_messages_sent_count () const
	Number of messages that contain transaction data sent by this member. More...

uint64_t	get_control_messages_sent_bytes_sum () const
	Sum of bytes of control messages sent by this member. More...

uint64_t	get_data_messages_sent_bytes_sum () const
	Sum of bytes of messages that contain transaction data sent by this member. More...

uint64_t	get_control_messages_sent_roundtrip_time_sum () const
	Sum of the roundtrip time in micro-seconds of control messages sent by this member. More...

uint64_t	get_data_messages_sent_roundtrip_time_sum () const
	Sum of the roundtrip time in micro-seconds of messages that contain transaction data sent by this member. More...

uint64_t	get_transactions_consistency_before_begin_count () const
	Number of transactions executed with group_replication_consistency=BEFORE or BEFORE_AND_AFTER. More...

uint64_t	get_transactions_consistency_before_begin_time_sum () const
	Sum of the time that the member waited until its `group_replication_applier` channel was consumed before execute the transaction with group_replication_consistency=BEFORE or BEFORE_AND_AFTER. More...

uint64_t	get_transactions_consistency_after_termination_count () const
	Number of transactions executed with group_replication_consistency=AFTER or BEFORE_AND_AFTER. More...

uint64_t	get_transactions_consistency_after_termination_time_sum () const
	Sum of the time spent between the delivery of the transaction executed with group_replication_consistency= AFTER or BEFORE_AND_AFTER, and the acknowledge of the other group members that the transaction is prepared. More...

uint64_t	get_transactions_consistency_after_sync_count () const
	Number of transactions executed with group_replication_consistency=AFTER or BEFORE_AND_AFTER. More...

uint64_t	get_transactions_consistency_after_sync_time_sum () const
	Sum of the time that transactions on secondaries waited to start, while waiting for transactions from the primary with group_replication_consistency=AFTER or BEFORE_AND_AFTER to be committed. More...

uint64_t	get_certification_garbage_collector_count () const
	Number of times certification garbage collection did run. More...

uint64_t	get_certification_garbage_collector_time_sum () const
	Sum of the time that garbage collection runs took. More...

void	add_message_sent (const Gcs_message &message)
	Account message sent. More...

void	add_transaction_consistency_before_begin (const uint64_t begin_timestamp, const uint64_t end_timestamp)
	Account transaction that waited until its `group_replication_applier` channel was consumed before execute the transaction with group_replication_consistency=BEFORE or BEFORE_AND_AFTER. More...

void	add_transaction_consistency_after_termination (const uint64_t begin_timestamp, const uint64_t end_timestamp)
	Account transaction executed with group_replication_consistency=AFTER or BEFORE_AND_AFTER that waited for the acknowledge of the other group members that the transaction is prepared. More...

void	add_transaction_consistency_after_sync (const uint64_t begin_timestamp, const uint64_t end_timestamp)
	Account transaction that waited for transactions from the primary with group_replication_consistency=AFTER or BEFORE_AND_AFTER to be committed. More...

void	add_garbage_collection_run (const uint64_t begin_timestamp, const uint64_t end_timestamp)
	Account a certification garbage collection run. More...

uint64_t	get_flow_control_throttle_count () const
	Number of times flow control did run. More...

uint64_t	get_flow_control_throttle_time () const
	Total time flow control delayed transactions. More...

uint64_t	get_flow_control_throttle_active () const
	Flow control is active. More...

uint64_t	get_flow_control_throttle_last_throttle_timestamp () const
	Flow control last timestamp of a transaction being throttled. More...

void	add_flow_control_throttle_stats (const uint64_t begin_timestamp, const uint64_t end_timestamp)
	Update state of flow control. More...

void	increment_flow_control_throttle ()
	Increment number of transactions currently throttled. More...

void	decrement_flow_control_throttle ()
	Decrement number of transactions currently throttled. More...

Static Public Member Functions
static uint64_t	get_current_time ()
	Return time in microseconds since the Epoch, 1970-01-01 00:00:00 +0000 (UTC) More...

Private Member Functions
void	add_message_sent_internal (const enum_message_type type, const uint64_t bytes, const uint64_t sent_timestamp, const uint64_t received_timestamp)
	Account message sent. More...

Private Attributes
std::atomic< uint64_t >	m_control_messages_sent_count {0}

std::atomic< uint64_t >	m_data_messages_sent_count {0}

std::atomic< uint64_t >	m_control_messages_sent_bytes_sum {0}

std::atomic< uint64_t >	m_data_messages_sent_bytes_sum {0}

std::atomic< uint64_t >	m_control_messages_sent_roundtrip_time_sum {0}

std::atomic< uint64_t >	m_data_messages_sent_roundtrip_time_sum {0}

std::atomic< uint64_t >	m_transactions_consistency_before_begin_count {0}

std::atomic< uint64_t >	m_transactions_consistency_before_begin_time_sum {0}

std::atomic< uint64_t >	m_transactions_consistency_after_termination_count {0}

std::atomic< uint64_t >	m_transactions_consistency_after_termination_time_sum

std::atomic< uint64_t >	m_transactions_consistency_after_sync_count {0}

std::atomic< uint64_t >	m_transactions_consistency_after_sync_time_sum {0}

std::atomic< uint64_t >	m_certification_garbage_collector_count {0}

std::atomic< uint64_t >	m_certification_garbage_collector_time_sum {0}

std::atomic< uint64_t >	m_flow_control_count {0}

std::atomic< uint64_t >	m_flow_control_throttle_active {0}

std::atomic< uint64_t >	m_flow_control_throttle_time {0}

std::atomic< uint64_t >	m_flow_control_throttle_last_throttle_timestamp {0}

Member Enumeration Documentation

◆ enum_message_type

enum class Metrics_handler::enum_message_type

strong

Enumerator
CONTROL
DATA

Constructor & Destructor Documentation

◆ Metrics_handler()

Metrics_handler::Metrics_handler ( )

default

◆ ~Metrics_handler()

virtual Metrics_handler::~Metrics_handler ( )

virtualdefault

Member Function Documentation

◆ add_flow_control_throttle_stats()

void Metrics_handler::add_flow_control_throttle_stats	(	const uint64_t	begin_timestamp,
		const uint64_t	end_timestamp
	)

Update state of flow control.

See also: Metrics_handler::get_current_time()

Parameters

begin_timestamp	time on which the operation began.
end_timestamp	time on which the operation ended.

◆ add_garbage_collection_run()

void Metrics_handler::add_garbage_collection_run	(	const uint64_t	begin_timestamp,
		const uint64_t	end_timestamp
	)

Account a certification garbage collection run.

See also: Metrics_handler::get_current_time()

Parameters

begin_timestamp	time on which the operation began.
end_timestamp	time on which the operation ended.

◆ add_message_sent()

void Metrics_handler::add_message_sent ( const Gcs_message & message )

Account message sent.

Parameters

message the message to be accounted.

◆ add_message_sent_internal()

void Metrics_handler::add_message_sent_internal	(	const enum_message_type	type,
		const uint64_t	bytes,
		const uint64_t	sent_timestamp,
		const uint64_t	received_timestamp
	)

private

Account message sent.

See also: Metrics_handler::get_current_time()

Parameters

type	message type.
bytes	message length.
sent_timestamp	time on which the message was sent.
received_timestamp	time on which the message was received.

◆ add_transaction_consistency_after_sync()

void Metrics_handler::add_transaction_consistency_after_sync	(	const uint64_t	begin_timestamp,
		const uint64_t	end_timestamp
	)

Account transaction that waited for transactions from the primary with group_replication_consistency=AFTER or BEFORE_AND_AFTER to be committed.

See also: Metrics_handler::get_current_time()

Parameters

begin_timestamp	time on which the wait began.
end_timestamp	time on which the wait ended.

◆ add_transaction_consistency_after_termination()

void Metrics_handler::add_transaction_consistency_after_termination	(	const uint64_t	begin_timestamp,
		const uint64_t	end_timestamp
	)

Account transaction executed with group_replication_consistency=AFTER or BEFORE_AND_AFTER that waited for the acknowledge of the other group members that the transaction is prepared.

See also: Metrics_handler::get_current_time()

Parameters

begin_timestamp	time on which the wait began.
end_timestamp	time on which the wait ended.

◆ add_transaction_consistency_before_begin()

void Metrics_handler::add_transaction_consistency_before_begin	(	const uint64_t	begin_timestamp,
		const uint64_t	end_timestamp
	)

Account transaction that waited until its group_replication_applier channel was consumed before execute the transaction with group_replication_consistency=BEFORE or BEFORE_AND_AFTER.

See also: Metrics_handler::get_current_time()

Parameters

begin_timestamp	time on which the wait began.
end_timestamp	time on which the wait ended.

◆ decrement_flow_control_throttle()

void Metrics_handler::decrement_flow_control_throttle ( )

Decrement number of transactions currently throttled.

◆ get_certification_garbage_collector_count()

uint64_t Metrics_handler::get_certification_garbage_collector_count ( ) const

Number of times certification garbage collection did run.

Returns: number of garbage collect runs.

◆ get_certification_garbage_collector_time_sum()

uint64_t Metrics_handler::get_certification_garbage_collector_time_sum ( ) const

Sum of the time that garbage collection runs took.

See also: Metrics_handler::get_current_time()

Returns: sum of the time.

◆ get_control_messages_sent_bytes_sum()

uint64_t Metrics_handler::get_control_messages_sent_bytes_sum ( ) const

Sum of bytes of control messages sent by this member.

The size is the over the wire size.

Returns: sum of bytes.

◆ get_control_messages_sent_count()

uint64_t Metrics_handler::get_control_messages_sent_count ( ) const

Number of control messages sent by this member.

Returns: number of messages.

◆ get_control_messages_sent_roundtrip_time_sum()

uint64_t Metrics_handler::get_control_messages_sent_roundtrip_time_sum ( ) const

Sum of the roundtrip time in micro-seconds of control messages sent by this member.

The time is measured between the send and the delivery of the message on the sender member.

See also: Metrics_handler::get_current_time()

Returns: sum of the roundtrip time.

◆ get_current_time()

static uint64_t Metrics_handler::get_current_time ( )

inlinestatic

Return time in microseconds since the Epoch, 1970-01-01 00:00:00 +0000 (UTC)

Returns: time in microseconds.

◆ get_data_messages_sent_bytes_sum()

uint64_t Metrics_handler::get_data_messages_sent_bytes_sum ( ) const

Sum of bytes of messages that contain transaction data sent by this member.

The size is the over the wire size.

Returns: sum of bytes.

◆ get_data_messages_sent_count()

uint64_t Metrics_handler::get_data_messages_sent_count ( ) const

Number of messages that contain transaction data sent by this member.

Returns: number of messages.

◆ get_data_messages_sent_roundtrip_time_sum()

uint64_t Metrics_handler::get_data_messages_sent_roundtrip_time_sum ( ) const

Sum of the roundtrip time in micro-seconds of messages that contain transaction data sent by this member.

The time is measured between the send and the delivery of the message on the sender member.

See also: Metrics_handler::get_current_time()

Returns: sum of the roundtrip time.

◆ get_flow_control_throttle_active()

uint64_t Metrics_handler::get_flow_control_throttle_active ( ) const

Flow control is active.

Returns: number of transactions being throttled.

◆ get_flow_control_throttle_count()

uint64_t Metrics_handler::get_flow_control_throttle_count ( ) const

Number of times flow control did run.

Returns: number of transactions throttled.

◆ get_flow_control_throttle_last_throttle_timestamp()

uint64_t Metrics_handler::get_flow_control_throttle_last_throttle_timestamp ( ) const

Flow control last timestamp of a transaction being throttled.

Returns: microseconds since epoch

◆ get_flow_control_throttle_time()

uint64_t Metrics_handler::get_flow_control_throttle_time ( ) const

Total time flow control delayed transactions.

Returns: time flow control delayed transactions

◆ get_transactions_consistency_after_sync_count()

uint64_t Metrics_handler::get_transactions_consistency_after_sync_count ( ) const

Number of transactions executed with group_replication_consistency=AFTER or BEFORE_AND_AFTER.

Returns: number of transactions.

◆ get_transactions_consistency_after_sync_time_sum()

uint64_t Metrics_handler::get_transactions_consistency_after_sync_time_sum ( ) const

Sum of the time that transactions on secondaries waited to start, while waiting for transactions from the primary with group_replication_consistency=AFTER or BEFORE_AND_AFTER to be committed.

See also: Metrics_handler::get_current_time()

Returns: sum of the wait time.

◆ get_transactions_consistency_after_termination_count()

uint64_t Metrics_handler::get_transactions_consistency_after_termination_count ( ) const

Number of transactions executed with group_replication_consistency=AFTER or BEFORE_AND_AFTER.

Returns: number of transactions.

◆ get_transactions_consistency_after_termination_time_sum()

uint64_t Metrics_handler::get_transactions_consistency_after_termination_time_sum ( ) const

Sum of the time spent between the delivery of the transaction executed with group_replication_consistency= AFTER or BEFORE_AND_AFTER, and the acknowledge of the other group members that the transaction is prepared.

See also: Metrics_handler::get_current_time()

Returns: sum of the wait time.

◆ get_transactions_consistency_before_begin_count()

uint64_t Metrics_handler::get_transactions_consistency_before_begin_count ( ) const

Number of transactions executed with group_replication_consistency=BEFORE or BEFORE_AND_AFTER.

Returns: number of transactions.

◆ get_transactions_consistency_before_begin_time_sum()

uint64_t Metrics_handler::get_transactions_consistency_before_begin_time_sum ( ) const

Sum of the time that the member waited until its group_replication_applier channel was consumed before execute the transaction with group_replication_consistency=BEFORE or BEFORE_AND_AFTER.

See also: Metrics_handler::get_current_time()

Returns: sum of the wait time.

◆ increment_flow_control_throttle()

void Metrics_handler::increment_flow_control_throttle ( )

Increment number of transactions currently throttled.

◆ reset()

void Metrics_handler::reset ( )

Reset the metrics.

Member Data Documentation

◆ m_certification_garbage_collector_count

std::atomic<uint64_t> Metrics_handler::m_certification_garbage_collector_count {0}

private

◆ m_certification_garbage_collector_time_sum

std::atomic<uint64_t> Metrics_handler::m_certification_garbage_collector_time_sum {0}

private

◆ m_control_messages_sent_bytes_sum

std::atomic<uint64_t> Metrics_handler::m_control_messages_sent_bytes_sum {0}

private

◆ m_control_messages_sent_count

std::atomic<uint64_t> Metrics_handler::m_control_messages_sent_count {0}

private

◆ m_control_messages_sent_roundtrip_time_sum

std::atomic<uint64_t> Metrics_handler::m_control_messages_sent_roundtrip_time_sum {0}

private

◆ m_data_messages_sent_bytes_sum

std::atomic<uint64_t> Metrics_handler::m_data_messages_sent_bytes_sum {0}

private

◆ m_data_messages_sent_count

std::atomic<uint64_t> Metrics_handler::m_data_messages_sent_count {0}

private

◆ m_data_messages_sent_roundtrip_time_sum

std::atomic<uint64_t> Metrics_handler::m_data_messages_sent_roundtrip_time_sum {0}

private

◆ m_flow_control_count

std::atomic<uint64_t> Metrics_handler::m_flow_control_count {0}

private

◆ m_flow_control_throttle_active

std::atomic<uint64_t> Metrics_handler::m_flow_control_throttle_active {0}

private

◆ m_flow_control_throttle_last_throttle_timestamp

std::atomic<uint64_t> Metrics_handler::m_flow_control_throttle_last_throttle_timestamp {0}

private

◆ m_flow_control_throttle_time

std::atomic<uint64_t> Metrics_handler::m_flow_control_throttle_time {0}

private

◆ m_transactions_consistency_after_sync_count

std::atomic<uint64_t> Metrics_handler::m_transactions_consistency_after_sync_count {0}

private

◆ m_transactions_consistency_after_sync_time_sum

std::atomic<uint64_t> Metrics_handler::m_transactions_consistency_after_sync_time_sum {0}

private

◆ m_transactions_consistency_after_termination_count

std::atomic<uint64_t> Metrics_handler::m_transactions_consistency_after_termination_count {0}

private

◆ m_transactions_consistency_after_termination_time_sum

std::atomic<uint64_t> Metrics_handler::m_transactions_consistency_after_termination_time_sum

private

Initial value:

{

0}

◆ m_transactions_consistency_before_begin_count

std::atomic<uint64_t> Metrics_handler::m_transactions_consistency_before_begin_count {0}

private

◆ m_transactions_consistency_before_begin_time_sum

std::atomic<uint64_t> Metrics_handler::m_transactions_consistency_before_begin_time_sum {0}

private

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

plugin/group_replication/include/plugin_handlers/metrics_handler.h
plugin/group_replication/src/plugin_handlers/metrics_handler.cc

Public Types

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Member Enumeration Documentation

◆ enum_message_type

Constructor & Destructor Documentation

◆ Metrics_handler()

◆ ~Metrics_handler()

Member Function Documentation

◆ add_flow_control_throttle_stats()

◆ add_garbage_collection_run()

◆ add_message_sent()

◆ add_message_sent_internal()

◆ add_transaction_consistency_after_sync()

◆ add_transaction_consistency_after_termination()

◆ add_transaction_consistency_before_begin()

◆ decrement_flow_control_throttle()

◆ get_certification_garbage_collector_count()

◆ get_certification_garbage_collector_time_sum()

◆ get_control_messages_sent_bytes_sum()

◆ get_control_messages_sent_count()

◆ get_control_messages_sent_roundtrip_time_sum()

◆ get_current_time()

◆ get_data_messages_sent_bytes_sum()

◆ get_data_messages_sent_count()

◆ get_data_messages_sent_roundtrip_time_sum()

◆ get_flow_control_throttle_active()

◆ get_flow_control_throttle_count()

◆ get_flow_control_throttle_last_throttle_timestamp()

◆ get_flow_control_throttle_time()

◆ get_transactions_consistency_after_sync_count()

◆ get_transactions_consistency_after_sync_time_sum()

◆ get_transactions_consistency_after_termination_count()

◆ get_transactions_consistency_after_termination_time_sum()

◆ get_transactions_consistency_before_begin_count()

◆ get_transactions_consistency_before_begin_time_sum()

◆ increment_flow_control_throttle()

◆ reset()

Member Data Documentation

◆ m_certification_garbage_collector_count

◆ m_certification_garbage_collector_time_sum

◆ m_control_messages_sent_bytes_sum

◆ m_control_messages_sent_count

◆ m_control_messages_sent_roundtrip_time_sum

◆ m_data_messages_sent_bytes_sum

◆ m_data_messages_sent_count

◆ m_data_messages_sent_roundtrip_time_sum

◆ m_flow_control_count

◆ m_flow_control_throttle_active

◆ m_flow_control_throttle_last_throttle_timestamp

◆ m_flow_control_throttle_time

◆ m_transactions_consistency_after_sync_count

◆ m_transactions_consistency_after_sync_time_sum

◆ m_transactions_consistency_after_termination_count

◆ m_transactions_consistency_after_termination_time_sum

◆ m_transactions_consistency_before_begin_count

◆ m_transactions_consistency_before_begin_time_sum