MySQL 9.1.0
Source Code Documentation
Public Member Functions | List of all members
Asynchronous_channels_state_observer Class Reference

#include <asynchronous_channels_state_observer.h>

Inheritance diagram for Asynchronous_channels_state_observer:
[legend]

Public Member Functions

 Asynchronous_channels_state_observer ()
 
int thread_start (Binlog_relay_IO_param *param) override
 Observer for receiver thread starts. More...
 
int thread_stop (Binlog_relay_IO_param *param) override
 Observer for receiver thread stops. More...
 
int applier_start (Binlog_relay_IO_param *param) override
 Observer for applier thread starts. More...
 
int applier_stop (Binlog_relay_IO_param *param, bool aborted) override
 Observer for applier thread stops. More...
 
int before_request_transmit (Binlog_relay_IO_param *param, uint32 flags) override
 Observer for when a new transmission from a another server is requested. More...
 
int after_read_event (Binlog_relay_IO_param *param, const char *packet, unsigned long len, const char **event_buf, unsigned long *event_len) override
 Observer for whenever a event is read by the receiver thread. More...
 
int after_queue_event (Binlog_relay_IO_param *param, const char *event_buf, unsigned long event_len, uint32 flags) override
 Observer for whenever a event is queued by the receiver thread. More...
 
int after_reset_slave (Binlog_relay_IO_param *param) override
 Observer for whenever a reset replica is executed. More...
 
int applier_log_event (Binlog_relay_IO_param *param, Trans_param *trans_param, int &out) override
 Observer for event applied through applier thread. More...
 
- Public Member Functions inherited from Channel_state_observer
virtual ~Channel_state_observer ()=0
 

Constructor & Destructor Documentation

◆ Asynchronous_channels_state_observer()

Asynchronous_channels_state_observer::Asynchronous_channels_state_observer ( )
default

Member Function Documentation

◆ after_queue_event()

int Asynchronous_channels_state_observer::after_queue_event ( Binlog_relay_IO_param *  param,
const char *  event_buf,
unsigned long  event_len,
uint32  flags 
)
overridevirtual

Observer for whenever a event is queued by the receiver thread.

Implements Channel_state_observer.

◆ after_read_event()

int Asynchronous_channels_state_observer::after_read_event ( Binlog_relay_IO_param *  param,
const char *  packet,
unsigned long  len,
const char **  event_buf,
unsigned long *  event_len 
)
overridevirtual

Observer for whenever a event is read by the receiver thread.

Implements Channel_state_observer.

◆ after_reset_slave()

int Asynchronous_channels_state_observer::after_reset_slave ( Binlog_relay_IO_param *  param)
overridevirtual

Observer for whenever a reset replica is executed.

Implements Channel_state_observer.

◆ applier_log_event()

int Asynchronous_channels_state_observer::applier_log_event ( Binlog_relay_IO_param *  param,
Trans_param *  trans_param,
int &  out 
)
overridevirtual

Observer for event applied through applier thread.

Implements Channel_state_observer.

◆ applier_start()

int Asynchronous_channels_state_observer::applier_start ( Binlog_relay_IO_param *  param)
overridevirtual

Observer for applier thread starts.

Implements Channel_state_observer.

◆ applier_stop()

int Asynchronous_channels_state_observer::applier_stop ( Binlog_relay_IO_param *  param,
bool  aborted 
)
overridevirtual

Observer for applier thread stops.

Implements Channel_state_observer.

◆ before_request_transmit()

int Asynchronous_channels_state_observer::before_request_transmit ( Binlog_relay_IO_param *  param,
uint32  flags 
)
overridevirtual

Observer for when a new transmission from a another server is requested.

Implements Channel_state_observer.

◆ thread_start()

int Asynchronous_channels_state_observer::thread_start ( Binlog_relay_IO_param *  param)
overridevirtual

Observer for receiver thread starts.

Implements Channel_state_observer.

◆ thread_stop()

int Asynchronous_channels_state_observer::thread_stop ( Binlog_relay_IO_param *  param)
overridevirtual

Observer for receiver thread stops.

Implements Channel_state_observer.

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