mysql::csa::Channel Class Reference

Represents a channel in the Change Stream Applier (CSA). More...

#include <channel.h>

Public Member Functions
	Channel (const std::string &name, unsigned int instance_id, Commit_order_manager *commit_order_manager)
	Constructor. More...
virtual	~Channel ()
	Destructor. More...
const std::string &	get_name () const
	Obtains the name of the channel. More...
Commit_order_manager *	get_commit_order_manager () const
	Commit order manager accessor. More...
unsigned int	get_channel_id () const

Protected Attributes
const std::string	m_name
	The name of the channel. More...
unsigned int	m_instance_id {0}
	Unique id of the channel. More...
Commit_order_manager *	m_commit_order_manager
	Pointer to the commit order manager. More...

Detailed Description

Represents a channel in the Change Stream Applier (CSA).

Constructor & Destructor Documentation

Channel()

Channel::Channel	(	const std::string &	name,
		unsigned int	instance_id,
		Commit_order_manager *	commit_order_manager
	)

Constructor.

Parameters

name	Name of the channel
instance_id	Unique id of the channel
commit_order_manager	Pointer to the commit order manager

~Channel()

Channel::~Channel ( )

virtual

Destructor.

Member Function Documentation

get_channel_id()

unsigned int Channel::get_channel_id

(

)

const

get_commit_order_manager()

Commit_order_manager * Channel::get_commit_order_manager

(

)

const

Commit order manager accessor.

Returns

Pointer to the commit order manager instance for this channel

get_name()

const std::string & Channel::get_name

(

)

const

Obtains the name of the channel.

Returns

Channel name

Member Data Documentation

m_commit_order_manager

Commit_order_manager* mysql::csa::Channel::m_commit_order_manager

protected

Pointer to the commit order manager.

m_instance_id

unsigned int mysql::csa::Channel::m_instance_id {0}

protected

Unique id of the channel.

m_name

const std::string mysql::csa::Channel::m_name

protected

The name of the channel.

---

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

• sql/changestreams/apply/context/channel.h
• sql/changestreams/apply/context/channel.cpp