1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
#ifndef MYGRATE_EVENTHANDLERS_H
#define MYGRATE_EVENTHANDLERS_H
#include "eventHandlerBase.h"
#include <array>
#include <string_view>
namespace MyGrate {
struct EventHandler {
std::string_view name;
void (MyGrate::EventHandlerBase::*func)(MyGrate::MariaDB_Event_Ptr);
};
using EventHandlers = std::array<EventHandler, ENUM_END_EVENT>;
constexpr EventHandlers eventHandlers {[]() {
EventHandlers eh {};
eh[UNKNOWN_EVENT] = {"UNKNOWN_EVENT", nullptr};
eh[START_EVENT_V3] = {"START_EVENT_V3", nullptr};
eh[QUERY_EVENT] = {"QUERY_EVENT", nullptr};
eh[STOP_EVENT] = {"STOP_EVENT", nullptr};
eh[ROTATE_EVENT] = {"ROTATE_EVENT", &MyGrate::EventHandlerBase::rotate};
eh[INTVAR_EVENT] = {"INTVAR_EVENT", nullptr};
eh[LOAD_EVENT] = {"LOAD_EVENT", nullptr};
eh[SLAVE_EVENT] = {"SLAVE_EVENT", nullptr};
eh[CREATE_FILE_EVENT] = {"CREATE_FILE_EVENT", nullptr};
eh[APPEND_BLOCK_EVENT] = {"APPEND_BLOCK_EVENT", nullptr};
eh[EXEC_LOAD_EVENT] = {"EXEC_LOAD_EVENT", nullptr};
eh[DELETE_FILE_EVENT] = {"DELETE_FILE_EVENT", nullptr};
eh[NEW_LOAD_EVENT] = {"NEW_LOAD_EVENT", nullptr};
eh[RAND_EVENT] = {"RAND_EVENT", nullptr};
eh[USER_VAR_EVENT] = {"USER_VAR_EVENT", nullptr};
eh[FORMAT_DESCRIPTION_EVENT] = {"FORMAT_DESCRIPTION_EVENT", nullptr};
eh[XID_EVENT] = {"XID_EVENT", nullptr};
eh[BEGIN_LOAD_QUERY_EVENT] = {"BEGIN_LOAD_QUERY_EVENT", nullptr};
eh[EXECUTE_LOAD_QUERY_EVENT] = {"EXECUTE_LOAD_QUERY_EVENT", nullptr};
eh[TABLE_MAP_EVENT] = {"TABLE_MAP_EVENT", &MyGrate::EventHandlerBase::tableMap};
eh[PRE_GA_WRITE_ROWS_EVENT] = {"PRE_GA_WRITE_ROWS_EVENT", nullptr};
eh[PRE_GA_UPDATE_ROWS_EVENT] = {"PRE_GA_UPDATE_ROWS_EVENT", nullptr};
eh[PRE_GA_DELETE_ROWS_EVENT] = {"PRE_GA_DELETE_ROWS_EVENT", nullptr};
eh[WRITE_ROWS_EVENT_V1] = {"WRITE_ROWS_EVENT_V1", &MyGrate::EventHandlerBase::insertRow};
eh[UPDATE_ROWS_EVENT_V1] = {"UPDATE_ROWS_EVENT_V1", &MyGrate::EventHandlerBase::updateRow};
eh[DELETE_ROWS_EVENT_V1] = {"DELETE_ROWS_EVENT_V1", &MyGrate::EventHandlerBase::deleteRow};
eh[INCIDENT_EVENT] = {"INCIDENT_EVENT", nullptr};
eh[HEARTBEAT_LOG_EVENT] = {"HEARTBEAT_LOG_EVENT", nullptr};
eh[IGNORABLE_LOG_EVENT] = {"IGNORABLE_LOG_EVENT", nullptr};
eh[ROWS_QUERY_LOG_EVENT] = {"ROWS_QUERY_LOG_EVENT", nullptr};
eh[WRITE_ROWS_EVENT] = {"WRITE_ROWS_EVENT", nullptr};
eh[UPDATE_ROWS_EVENT] = {"UPDATE_ROWS_EVENT", nullptr};
eh[DELETE_ROWS_EVENT] = {"DELETE_ROWS_EVENT", nullptr};
eh[GTID_LOG_EVENT] = {"GTID_LOG_EVENT", nullptr};
eh[ANONYMOUS_GTID_LOG_EVENT] = {"ANONYMOUS_GTID_LOG_EVENT", nullptr};
eh[PREVIOUS_GTIDS_LOG_EVENT] = {"PREVIOUS_GTIDS_LOG_EVENT", nullptr};
eh[TRANSACTION_CONTEXT_EVENT] = {"TRANSACTION_CONTEXT_EVENT", nullptr};
eh[VIEW_CHANGE_EVENT] = {"VIEW_CHANGE_EVENT", nullptr};
eh[XA_PREPARE_LOG_EVENT] = {"XA_PREPARE_LOG_EVENT", nullptr};
eh[MARIA_EVENTS_BEGIN] = {"MARIA_EVENTS_BEGIN", nullptr};
eh[ANNOTATE_ROWS_EVENT] = {"ANNOTATE_ROWS_EVENT", nullptr};
eh[BINLOG_CHECKPOINT_EVENT] = {"BINLOG_CHECKPOINT_EVENT", nullptr};
eh[GTID_EVENT] = {"GTID_EVENT", nullptr};
eh[GTID_LIST_EVENT] = {"GTID_LIST_EVENT", nullptr};
eh[START_ENCRYPTION_EVENT] = {"START_ENCRYPTION_EVENT", nullptr};
eh[QUERY_COMPRESSED_EVENT] = {"QUERY_COMPRESSED_EVENT", nullptr};
eh[WRITE_ROWS_COMPRESSED_EVENT_V1] = {"WRITE_ROWS_COMPRESSED_EVENT_V1", nullptr};
eh[UPDATE_ROWS_COMPRESSED_EVENT_V1] = {"UPDATE_ROWS_COMPRESSED_EVENT_V1", nullptr};
eh[DELETE_ROWS_COMPRESSED_EVENT_V1] = {"DELETE_ROWS_COMPRESSED_EVENT_V1", nullptr};
eh[WRITE_ROWS_COMPRESSED_EVENT] = {"WRITE_ROWS_COMPRESSED_EVENT", nullptr};
eh[UPDATE_ROWS_COMPRESSED_EVENT] = {"UPDATE_ROWS_COMPRESSED_EVENT", nullptr};
eh[DELETE_ROWS_COMPRESSED_EVENT] = {"DELETE_ROWS_COMPRESSED_EVENT", nullptr};
return eh;
}()};
}
#endif
|
