CT_CERTIFICATION_MESSAGE enum value | Plugin_gcs_message | |
CT_GROUP_ACTION_MESSAGE enum value | Plugin_gcs_message | |
CT_GROUP_VALIDATION_MESSAGE enum value | Plugin_gcs_message | |
CT_MAX enum value | Plugin_gcs_message | |
CT_MEMBER_INFO_MANAGER_MESSAGE enum value | Plugin_gcs_message | |
CT_MEMBER_INFO_MESSAGE enum value | Plugin_gcs_message | |
CT_MESSAGE_SERVICE_MESSAGE enum value | Plugin_gcs_message | |
CT_PIPELINE_STATS_MEMBER_MESSAGE enum value | Plugin_gcs_message | |
CT_RECOVERY_MESSAGE enum value | Plugin_gcs_message | |
CT_RECOVERY_METADATA_MESSAGE enum value | Plugin_gcs_message | |
CT_SINGLE_PRIMARY_MESSAGE enum value | Plugin_gcs_message | |
CT_SYNC_BEFORE_EXECUTION_MESSAGE enum value | Plugin_gcs_message | |
CT_TRANSACTION_MESSAGE enum value | Plugin_gcs_message | |
CT_TRANSACTION_PREPARED_MESSAGE enum value | Plugin_gcs_message | |
CT_TRANSACTION_WITH_GUARANTEE_MESSAGE enum value | Plugin_gcs_message | |
CT_UNKNOWN enum value | Plugin_gcs_message | |
decode(const unsigned char *buffer, size_t length) | Plugin_gcs_message | |
decode_header(const unsigned char **slider) | Plugin_gcs_message | protected |
decode_payload(const unsigned char *buffer, const unsigned char *end) override | Pipeline_stats_member_message | protectedvirtual |
decode_payload_item_bytes(const unsigned char **buffer, uint16 *type, unsigned char *value, unsigned long long *length) | Plugin_gcs_message | protected |
decode_payload_item_char(const unsigned char **buffer, uint16 *type, unsigned char *value) | Plugin_gcs_message | protectedstatic |
decode_payload_item_int2(const unsigned char **buffer, uint16 *type, uint16 *value) | Plugin_gcs_message | protected |
decode_payload_item_int4(const unsigned char **buffer, uint16 *type, uint32 *value) | Plugin_gcs_message | protected |
decode_payload_item_int8(const unsigned char **buffer, uint16 *type, uint64 *value) | Plugin_gcs_message | protectedstatic |
decode_payload_item_string(const unsigned char **buffer, uint16 *type, std::string *value, unsigned long long *length) | Plugin_gcs_message | protected |
decode_payload_item_type_and_length(const unsigned char **buffer, uint16 *payload_item_type, unsigned long long *payload_item_length) | Plugin_gcs_message | protectedstatic |
encode(std::vector< unsigned char > *buffer) const | Plugin_gcs_message | |
encode_header(std::vector< unsigned char > *buffer) const | Plugin_gcs_message | protected |
encode_payload(std::vector< unsigned char > *buffer) const override | Pipeline_stats_member_message | protectedvirtual |
encode_payload_item_bytes(std::vector< unsigned char > *buffer, uint16 type, const unsigned char *value, unsigned long long length) const | Plugin_gcs_message | protected |
encode_payload_item_char(std::vector< unsigned char > *buffer, uint16 type, unsigned char value) const | Plugin_gcs_message | protected |
encode_payload_item_int2(std::vector< unsigned char > *buffer, uint16 type, uint16 value) const | Plugin_gcs_message | protected |
encode_payload_item_int4(std::vector< unsigned char > *buffer, uint16 type, uint32 value) const | Plugin_gcs_message | protected |
encode_payload_item_int8(std::vector< unsigned char > *buffer, uint16 type, ulonglong value) const | Plugin_gcs_message | protected |
encode_payload_item_string(std::vector< unsigned char > *buffer, uint16 type, const char *value, unsigned long long length) const | Plugin_gcs_message | protected |
encode_payload_item_type_and_length(std::vector< unsigned char > *buffer, uint16 payload_item_type, unsigned long long payload_item_length) const | Plugin_gcs_message | protected |
enum_cargo_type enum name | Plugin_gcs_message | |
enum_payload_item_type enum name | Pipeline_stats_member_message | |
get_cargo_type() const | Plugin_gcs_message | inline |
get_cargo_type(const unsigned char *buffer) | Plugin_gcs_message | static |
get_first_payload_item_raw_data(const unsigned char *buffer, const unsigned char **payload_item_data, size_t *payload_item_length) | Plugin_gcs_message | static |
get_flow_control_mode() | Pipeline_stats_member_message | |
get_header_length() | Plugin_gcs_message | inline |
get_msg_length() | Plugin_gcs_message | inline |
get_payload_item_type_raw_data(const unsigned char *buffer, const unsigned char *end, uint16 payload_item_type, const unsigned char **payload_item_data, unsigned long long *payload_item_length) | Plugin_gcs_message | static |
get_sent_timestamp(const unsigned char *buffer, size_t length) | Pipeline_stats_member_message | static |
Plugin_gcs_message::get_sent_timestamp(const unsigned char *buffer, size_t length, const uint16 timestamp_payload_item_type) | Plugin_gcs_message | protectedstatic |
get_transaction_committed_all_members() | Pipeline_stats_member_message | |
get_transaction_last_conflict_free() | Pipeline_stats_member_message | |
get_transactions_applied() | Pipeline_stats_member_message | |
get_transactions_certified() | Pipeline_stats_member_message | |
get_transactions_local() | Pipeline_stats_member_message | |
get_transactions_local_rollback() | Pipeline_stats_member_message | |
get_transactions_negative_certified() | Pipeline_stats_member_message | |
get_transactions_rows_validating() | Pipeline_stats_member_message | |
get_transactions_waiting_apply() | Pipeline_stats_member_message | |
get_transactions_waiting_certification() | Pipeline_stats_member_message | |
get_transation_gtids_present() const | Pipeline_stats_member_message | |
get_version() | Plugin_gcs_message | inline |
m_cargo_type | Plugin_gcs_message | private |
m_fixed_header_len | Plugin_gcs_message | private |
m_flow_control_mode | Pipeline_stats_member_message | private |
m_msg_len | Plugin_gcs_message | private |
m_transaction_gtids_present | Pipeline_stats_member_message | private |
m_transaction_last_conflict_free | Pipeline_stats_member_message | private |
m_transactions_applied | Pipeline_stats_member_message | private |
m_transactions_certified | Pipeline_stats_member_message | private |
m_transactions_committed_all_members | Pipeline_stats_member_message | private |
m_transactions_local | Pipeline_stats_member_message | private |
m_transactions_local_rollback | Pipeline_stats_member_message | private |
m_transactions_negative_certified | Pipeline_stats_member_message | private |
m_transactions_rows_validating | Pipeline_stats_member_message | private |
m_transactions_waiting_apply | Pipeline_stats_member_message | private |
m_transactions_waiting_certification | Pipeline_stats_member_message | private |
m_version | Plugin_gcs_message | private |
Pipeline_stats_member_message(int32 transactions_waiting_certification, int32 transactions_waiting_apply, int64 transactions_certified, int64 transactions_applied, int64 transactions_local, int64 transactions_negative_certified, int64 transactions_rows_validating, bool transaction_gtids, const std::string &transactions_committed_all_members, const std::string &transactions_last_conflict_free, int64 transactions_local_rollback, Flow_control_mode mode) | Pipeline_stats_member_message | |
Pipeline_stats_member_message(const unsigned char *buf, size_t len) | Pipeline_stats_member_message | |
PIT_FLOW_CONTROL_MODE enum value | Pipeline_stats_member_message | |
PIT_MAX enum value | Pipeline_stats_member_message | |
PIT_SENT_TIMESTAMP enum value | Pipeline_stats_member_message | |
PIT_TRANSACTION_GTIDS_PRESENT enum value | Pipeline_stats_member_message | |
PIT_TRANSACTION_LAST_CONFLICT_FREE enum value | Pipeline_stats_member_message | |
PIT_TRANSACTIONS_APPLIED enum value | Pipeline_stats_member_message | |
PIT_TRANSACTIONS_CERTIFIED enum value | Pipeline_stats_member_message | |
PIT_TRANSACTIONS_COMMITTED_ALL_MEMBERS enum value | Pipeline_stats_member_message | |
PIT_TRANSACTIONS_LOCAL enum value | Pipeline_stats_member_message | |
PIT_TRANSACTIONS_LOCAL_ROLLBACK enum value | Pipeline_stats_member_message | |
PIT_TRANSACTIONS_NEGATIVE_CERTIFIED enum value | Pipeline_stats_member_message | |
PIT_TRANSACTIONS_ROWS_VALIDATING enum value | Pipeline_stats_member_message | |
PIT_TRANSACTIONS_WAITING_APPLY enum value | Pipeline_stats_member_message | |
PIT_TRANSACTIONS_WAITING_CERTIFICATION enum value | Pipeline_stats_member_message | |
PIT_UNKNOWN enum value | Pipeline_stats_member_message | |
Plugin_gcs_message(enum_cargo_type cargo_type) | Plugin_gcs_message | explicitprotected |
PLUGIN_GCS_MESSAGE_VERSION | Plugin_gcs_message | static |
WIRE_CARGO_TYPE_SIZE | Plugin_gcs_message | static |
WIRE_FIXED_HEADER_SIZE | Plugin_gcs_message | static |
WIRE_HD_LEN_SIZE | Plugin_gcs_message | static |
WIRE_MSG_LEN_SIZE | Plugin_gcs_message | static |
WIRE_PAYLOAD_ITEM_HEADER_SIZE | Plugin_gcs_message | static |
WIRE_PAYLOAD_ITEM_LEN_SIZE | Plugin_gcs_message | static |
WIRE_PAYLOAD_ITEM_TYPE_SIZE | Plugin_gcs_message | static |
WIRE_VERSION_SIZE | Plugin_gcs_message | static |
~Pipeline_stats_member_message() override | Pipeline_stats_member_message | |
~Plugin_gcs_message()=default | Plugin_gcs_message | virtual |