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

#include <applier_channel_state_observer.h>

Inheritance diagram for Applier_channel_state_observer:
[legend]

Public Member Functions

 Applier_channel_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 applier log event. More...
 
- Public Member Functions inherited from Channel_state_observer
virtual ~Channel_state_observer ()=0
 

Constructor & Destructor Documentation

◆ Applier_channel_state_observer()

Applier_channel_state_observer::Applier_channel_state_observer ( )
default

Member Function Documentation

◆ after_queue_event()

int Applier_channel_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 Applier_channel_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 Applier_channel_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 Applier_channel_state_observer::applier_log_event ( Binlog_relay_IO_param *  param,
Trans_param *  trans_param,
int &  out 
)
overridevirtual

Observer for applier log event.

Implements Channel_state_observer.

◆ applier_start()

int Applier_channel_state_observer::applier_start ( Binlog_relay_IO_param *  param)
overridevirtual

Observer for applier thread starts.

Implements Channel_state_observer.

◆ applier_stop()

int Applier_channel_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 Applier_channel_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 Applier_channel_state_observer::thread_start ( Binlog_relay_IO_param *  param)
overridevirtual

Observer for receiver thread starts.

Implements Channel_state_observer.

◆ thread_stop()

int Applier_channel_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: