MySQL 9.1.0
Source Code Documentation
binlog::services::iterator Namespace Reference

Classes

class  FileStorage
 

Functions

static my_h_binlog_storage_iterator_impiterator_cast (my_h_binlog_storage_iterator iterator)
 Convenient function to cast the opaque iterator pointer. More...
 
static Previous_gtids_log_eventfind_previous_gtids_event (Binlog_file_reader &binlog_file_reader)
 Gets the previous gtids log event from the given reader. More...
 
static bool has_purged_needed_gtids_already (const Gtid_set &excluded)
 Checks whether transactions requested have been purged already or not. More...
 
static bool find_files (std::list< std::string > &files_in_index, const Gtid_set &excluded, std::list< std::string > &files)
 Computes the binlog files that one needs to handle to get the specified transactions. More...
 

Variables

const mysql_service_binlog_storage_iterator_t imp_server_binlog_storage_iterator
 

Function Documentation

◆ find_files()

static bool binlog::services::iterator::find_files ( std::list< std::string > &  files_in_index,
const Gtid_set excluded,
std::list< std::string > &  files 
)
static

Computes the binlog files that one needs to handle to get the specified transactions.

Parameters
files_in_indexThe contents of the index file.
excludedThe transactions that the consumer does not care about.
filesOutput parameter. If successful, this contains the list of files.
Returns
true if there was an error or there are not enough binlog to serve the request.
false success.

◆ find_previous_gtids_event()

static Previous_gtids_log_event * binlog::services::iterator::find_previous_gtids_event ( Binlog_file_reader binlog_file_reader)
static

Gets the previous gtids log event from the given reader.

Parameters
binlog_file_readerthe reader open
Returns
a pointer to the previous gtids log event

◆ has_purged_needed_gtids_already()

static bool binlog::services::iterator::has_purged_needed_gtids_already ( const Gtid_set excluded)
static

Checks whether transactions requested have been purged already or not.

Parameters
excludedThe set of transactions excluded transactions/to be ignored.
Returns
true if there are transactions in the purged set that were needed.
false if we are ignoring all purged transactions.

◆ iterator_cast()

static my_h_binlog_storage_iterator_imp * binlog::services::iterator::iterator_cast ( my_h_binlog_storage_iterator  iterator)
static

Convenient function to cast the opaque iterator pointer.

Parameters
iteratorthe opaque iterator pointer
Returns
a pointer to the casted iterator.

Variable Documentation

◆ imp_server_binlog_storage_iterator

const mysql_service_binlog_storage_iterator_t binlog::services::iterator::imp_server_binlog_storage_iterator
Initial value:
= {
FileStorage::get_storage_details,
FileStorage::get_next_entry_size,
}
static mysql_service_status_t deinit()
Component deinitialization.
Definition: audit_api_message_emit.cc:580
static mysql_service_status_t init()
Component initialization.
Definition: audit_api_message_emit.cc:571
static mysql_service_status_t get(THD **thd) noexcept
Definition: mysql_current_thread_reader_all_empty.cc:31