24#ifndef TABLE_REPLICATION_CONNECTION_STATUS_H
25#define TABLE_REPLICATION_CONNECTION_STATUS_H
56#ifndef ENUM_RPL_YES_NO
57#define ENUM_RPL_YES_NO
178 bool read_all)
override;
192 int rnd_pos(
const void *pos)
override;
194 int index_init(uint idx,
bool sorted)
override;
Definition: pfs_engine_table.h:299
Definition: pfs_engine_table.h:267
An abstract PERFORMANCE_SCHEMA table.
Definition: pfs_engine_table.h:69
Definition: table_replication_connection_status.h:122
PFS_key_name m_key
Definition: table_replication_connection_status.h:132
PFS_index_rpl_connection_status_by_channel()
Definition: table_replication_connection_status.h:124
bool match(Master_info *mi) override
Definition: table_replication_connection_status.cc:135
~PFS_index_rpl_connection_status_by_channel() override=default
Definition: table_replication_connection_status.h:136
~PFS_index_rpl_connection_status_by_thread() override=default
PFS_index_rpl_connection_status_by_thread()
Definition: table_replication_connection_status.h:138
bool match(Master_info *mi) override
Definition: table_replication_connection_status.cc:152
PFS_key_thread_id m_key
Definition: table_replication_connection_status.h:146
Definition: table_replication_connection_status.h:111
virtual bool match(Master_info *mi)=0
~PFS_index_rpl_connection_status() override=default
PFS_index_rpl_connection_status(PFS_engine_key *key)
Definition: table_replication_connection_status.h:113
Definition: table_helper.h:1508
Definition: table_helper.h:1251
Class to hold information regarding a table to be created on behalf of a plugin.
Definition: plugin_table.h:39
Table PERFORMANCE_SCHEMA.REPLICATION_CONNECTION_STATUS.
Definition: table_replication_connection_status.h:150
PFS_simple_index pos_t
Definition: table_replication_connection_status.h:151
int index_next() override
Find key in index, read record.
Definition: table_replication_connection_status.cc:253
int index_init(uint idx, bool sorted) override
Definition: table_replication_connection_status.cc:234
static PFS_engine_table * create(PFS_engine_table_share *)
Definition: table_replication_connection_status.cc:175
st_row_connect_status m_row
Current row.
Definition: table_replication_connection_status.h:162
void reset_position() override
Reset the cursor position to the beginning of the table.
Definition: table_replication_connection_status.cc:186
static ha_rows get_row_count()
Definition: table_replication_connection_status.cc:191
pos_t m_pos
Current position.
Definition: table_replication_connection_status.h:164
PFS_index_rpl_connection_status * m_opened_index
Definition: table_replication_connection_status.h:198
pos_t m_next_pos
Next position.
Definition: table_replication_connection_status.h:166
table_replication_connection_status()
Definition: table_replication_connection_status.cc:180
static Plugin_table m_table_def
Table definition.
Definition: table_replication_connection_status.h:159
int make_row(Master_info *mi)
Definition: table_replication_connection_status.cc:278
int rnd_next() override
Fetch the next row in this cursor.
Definition: table_replication_connection_status.cc:196
int rnd_pos(const void *pos) override
Fetch a row by position.
Definition: table_replication_connection_status.cc:215
int read_row_values(TABLE *table, unsigned char *buf, Field **fields, bool read_all) override
Read the current row values.
Definition: table_replication_connection_status.cc:407
static THR_LOCK m_table_lock
Table share lock.
Definition: table_replication_connection_status.h:157
~table_replication_connection_status() override
static PFS_engine_table_share m_share
Table share.
Definition: table_replication_connection_status.h:186
Fido Client Authentication nullptr
Definition: fido_client_plugin.cc:221
This file includes constants used by all storage engines.
my_off_t ha_rows
Definition: my_base.h:1139
Some integer typedefs for easier portability.
unsigned long long int ulonglong
Definition: my_inttypes.h:55
void my_free(void *ptr)
Frees the memory pointed by the ptr.
Definition: my_memory.cc:80
static PFS_engine_table_share_proxy table
Definition: pfs.cc:60
Definition: buf0block_hint.cc:29
Performance schema tables (declarations).
required string key
Definition: replication_asynchronous_connection_failover.proto:59
#define CHANNEL_NAME_LENGTH
Definition: rpl_info.h:40
#define MAX_SLAVE_ERRMSG
Maximum size of an error message from a slave thread.
Definition: rpl_reporting.h:41
File containing constants that can be used throughout the server.
constexpr const size_t UUID_LENGTH
Definition: sql_const.h:263
static const int MAX_TEXT_LENGTH
The maximal length of the textual representation of a SID, not including the terminating '\0'.
Definition: rpl_gtid.h:1111
A PERFORMANCE_SCHEMA table share.
Definition: pfs_engine_table.h:357
Position of a cursor, for simple iterations.
Definition: pfs_engine_table.h:557
Definition: thr_lock.h:138
Definition: table_replication_connection_status.h:71
int received_transaction_set_length
Definition: table_replication_connection_status.h:84
ulonglong last_queued_trx_immediate_commit_timestamp
Definition: table_replication_connection_status.h:92
ulonglong last_queued_trx_end_queue_timestamp
Definition: table_replication_connection_status.h:94
ulonglong queueing_trx_start_queue_timestamp
Definition: table_replication_connection_status.h:99
uint last_queued_trx_length
Definition: table_replication_connection_status.h:90
enum_rpl_connect_status_service_state service_state
Definition: table_replication_connection_status.h:80
ulonglong last_queued_trx_original_commit_timestamp
Definition: table_replication_connection_status.h:91
char group_name[UUID_LENGTH]
Definition: table_replication_connection_status.h:72
void cleanup()
Definition: table_replication_connection_status.h:103
ulonglong queueing_trx_original_commit_timestamp
Definition: table_replication_connection_status.h:97
char last_queued_trx[Gtid::MAX_TEXT_LENGTH+1]
Definition: table_replication_connection_status.h:89
char channel_name[CHANNEL_NAME_LENGTH]
Definition: table_replication_connection_status.h:74
char last_error_message[MAX_SLAVE_ERRMSG]
Definition: table_replication_connection_status.h:86
ulonglong last_queued_trx_start_queue_timestamp
Definition: table_replication_connection_status.h:93
st_row_connect_status()
Definition: table_replication_connection_status.h:101
ulonglong last_heartbeat_timestamp
Definition: table_replication_connection_status.h:82
bool thread_id_is_null
Definition: table_replication_connection_status.h:79
ulonglong thread_id
Definition: table_replication_connection_status.h:78
bool source_uuid_is_null
Definition: table_replication_connection_status.h:77
uint last_error_message_length
Definition: table_replication_connection_status.h:87
char * received_transaction_set
Definition: table_replication_connection_status.h:83
uint channel_name_length
Definition: table_replication_connection_status.h:75
char queueing_trx[Gtid::MAX_TEXT_LENGTH+1]
Definition: table_replication_connection_status.h:95
uint last_error_number
Definition: table_replication_connection_status.h:85
ulonglong last_error_timestamp
Definition: table_replication_connection_status.h:88
bool group_name_is_null
Definition: table_replication_connection_status.h:73
uint queueing_trx_length
Definition: table_replication_connection_status.h:96
ulonglong count_received_heartbeats
Definition: table_replication_connection_status.h:81
char source_uuid[UUID_LENGTH]
Definition: table_replication_connection_status.h:76
ulonglong queueing_trx_immediate_commit_timestamp
Definition: table_replication_connection_status.h:98
Helpers to implement a performance schema table.
enum_rpl_yes_no
Definition: table_replication_applier_configuration.h:49