cs::apply::instruments::Mta_worker_metrics Class Reference

This class contains metrics transaction execution in replica MTA workers. More...

#include <mta_worker_metrics.h>

Inheritance diagram for cs::apply::instruments::Mta_worker_metrics:

Public Member Functions
Mta_worker_metrics &	operator= (const Mta_worker_metrics &other)
	Copies stats from the given object into this one. More...
void	reset () override
	Resets the instruments on this instance. More...
Worker_metrics::Transaction_type_info	get_transaction_type () const override
	Returns the type of the currently being processed transaction. More...
void	set_transaction_type (Transaction_type_info type_info) override
	Set the type for the transaction being currently processed. More...
void	set_transaction_ongoing_full_size (int64_t amount) override
	set the full size of the ongoing transaction. More...
int64_t	get_transaction_ongoing_full_size () const override
	Gets the full size of the ongoing transaction. More...
void	inc_transaction_ongoing_progress_size (int64_t amount) override
	increment the executed size of the ongoing transaction. More...
void	reset_transaction_ongoing_progress_size () override
	Resets the the executed size of the ongoing transaction to 0. More...
int64_t	get_transaction_ongoing_progress_size () const override
	Gets the executed size of the ongoing transaction. More...
Time_based_metric_interface &	get_waits_due_to_commit_order () override
	Return time metric for waits on commit order. More...
Public Member Functions inherited from cs::apply::instruments::Worker_metrics
virtual	~Worker_metrics ()=default

Private Attributes
std::atomic< Transaction_type_info >	m_transaction_type
	The type of the transactions being handled. More...
Time_based_metric	m_waits_due_to_commit_order
	The number of time waited for commit order. More...
std::atomic_int64_t	m_transaction_ongoing_full_size {0}
	Holds the total full size of the transaction now ongoing. More...
std::atomic_int64_t	m_transaction_ongoing_progress_size {0}
	Holds the executed event's size of the transaction now ongoing. More...

Additional Inherited Members
Public Types inherited from cs::apply::instruments::Worker_metrics
enum class	Transaction_type_info { UNKNOWN , DML , DDL }
	This class helps signaling a transactions as DDL or DML. More...

Detailed Description

This class contains metrics transaction execution in replica MTA workers.

Member Function Documentation

get_transaction_ongoing_full_size()

int64_t cs::apply::instruments::Mta_worker_metrics::get_transaction_ongoing_full_size ( ) const

overridevirtual

Gets the full size of the ongoing transaction.

Returns

the total size of the ongoing transaction

Implements cs::apply::instruments::Worker_metrics.

get_transaction_ongoing_progress_size()

int64_t cs::apply::instruments::Mta_worker_metrics::get_transaction_ongoing_progress_size ( ) const

overridevirtual

Gets the executed size of the ongoing transaction.

Returns

the exectuted size of the ongoing transaction

Implements cs::apply::instruments::Worker_metrics.

get_transaction_type()

Mta_worker_metrics::Transaction_type_info cs::apply::instruments::Mta_worker_metrics::get_transaction_type ( ) const

overridevirtual

Returns the type of the currently being processed transaction.

Returns

If the type is unknown, DML or DDL

Implements cs::apply::instruments::Worker_metrics.

get_waits_due_to_commit_order()

Time_based_metric_interface & cs::apply::instruments::Mta_worker_metrics::get_waits_due_to_commit_order ( )

overridevirtual

Return time metric for waits on commit order.

Returns

a Time_based_metric_interface object that contains metric information on a wait

Implements cs::apply::instruments::Worker_metrics.

inc_transaction_ongoing_progress_size()

void cs::apply::instruments::Mta_worker_metrics::inc_transaction_ongoing_progress_size ( int64_t  amount )

overridevirtual

increment the executed size of the ongoing transaction.

Parameters

amount

the size amount to increment.

Implements cs::apply::instruments::Worker_metrics.

operator=()

Mta_worker_metrics & cs::apply::instruments::Mta_worker_metrics::operator=

(

const Mta_worker_metrics &

other

)

Copies stats from the given object into this one.

Parameters

other

the object to copy the stats from.

reset()

void cs::apply::instruments::Mta_worker_metrics::reset ( )

overridevirtual

Resets the instruments on this instance.

Implements cs::apply::instruments::Worker_metrics.

reset_transaction_ongoing_progress_size()

void cs::apply::instruments::Mta_worker_metrics::reset_transaction_ongoing_progress_size ( )

overridevirtual

Resets the the executed size of the ongoing transaction to 0.

Implements cs::apply::instruments::Worker_metrics.

set_transaction_ongoing_full_size()

void cs::apply::instruments::Mta_worker_metrics::set_transaction_ongoing_full_size ( int64_t  amount )

overridevirtual

set the full size of the ongoing transaction.

Parameters

amount

new size

Implements cs::apply::instruments::Worker_metrics.

set_transaction_type()

void cs::apply::instruments::Mta_worker_metrics::set_transaction_type ( Mta_worker_metrics::Transaction_type_info  type_info )

overridevirtual

Set the type for the transaction being currently processed.

Parameters

type_info

what is the type: UNKONWN, DML or DDL

Implements cs::apply::instruments::Worker_metrics.

Member Data Documentation

m_transaction_ongoing_full_size

std::atomic_int64_t cs::apply::instruments::Mta_worker_metrics::m_transaction_ongoing_full_size {0}

private

Holds the total full size of the transaction now ongoing.

m_transaction_ongoing_progress_size

std::atomic_int64_t cs::apply::instruments::Mta_worker_metrics::m_transaction_ongoing_progress_size {0}

private

Holds the executed event's size of the transaction now ongoing.

m_transaction_type

std::atomic<Transaction_type_info> cs::apply::instruments::Mta_worker_metrics::m_transaction_type

private

Initial value:

{
      Transaction_type_info::UNKNOWN}

The type of the transactions being handled.

m_waits_due_to_commit_order

Time_based_metric cs::apply::instruments::Mta_worker_metrics::m_waits_due_to_commit_order

private

The number of time waited for commit order.

---

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

• sql/changestreams/apply/metrics/mta_worker_metrics.h
• sql/changestreams/apply/metrics/mta_worker_metrics.cc