relay_log_adaptive_reader.cpp File Reference

#include "sql/changestreams/apply/storage/relay_log/relay_log_adaptive_reader.h"
#include <iomanip>
#include "mysql/psi/mysql_file.h"
#include "sql/changestreams/apply/service/csa_service.h"
#include "sql/changestreams/apply/storage/relay_log/event_set_fetchable_cache.h"
#include "sql/changestreams/apply/storage/relay_log/event_set_fetchable_relay_log.h"
#include "sql/changestreams/apply/storage/relay_log/reader_controller_read_type.h"
#include "sql/mysqld.h"
#include "sql/rpl_mi.h"

Namespaces
namespace	mysql
namespace	mysql::csa
namespace	mysql::csa::anonymous_namespace{relay_log_adaptive_reader.cpp}

Typedefs
using	Log_event_ptr = std::shared_ptr< Log_event >
using	Read_type = mysql::csa::Reader_controller_read_type
using	Statistics_map_sched = mysql::scheduler::Statistics_map
using	Statistics_monitor = mysql::scheduler::Statistics_monitor

Functions
std::size_t	mysql::csa::anonymous_namespace{relay_log_adaptive_reader.cpp}::get_gtid_transaction_length (Log_event *ev, Relay_log_info *rli, int64_t &prev)

Typedef Documentation

Log_event_ptr

using Log_event_ptr = std::shared_ptr<Log_event>

Read_type

using Read_type = mysql::csa::Reader_controller_read_type

Statistics_map_sched

using Statistics_map_sched = mysql::scheduler::Statistics_map

Statistics_monitor

using Statistics_monitor = mysql::scheduler::Statistics_monitor