This is the complete list of members for slave::QueueProducer, including all inherited members.
_check_interval | slave::QueueProducer | private |
_connection (defined in slave::QueueProducer) | slave::QueueProducer | private |
_drizzle (defined in slave::QueueProducer) | slave::QueueProducer | private |
_is_connected (defined in slave::QueueProducer) | slave::QueueProducer | private |
_last_error_message (defined in slave::QueueProducer) | slave::QueueProducer | private |
_last_return (defined in slave::QueueProducer) | slave::QueueProducer | private |
_master_host (defined in slave::QueueProducer) | slave::QueueProducer | private |
_master_id (defined in slave::QueueProducer) | slave::QueueProducer | private |
_master_pass (defined in slave::QueueProducer) | slave::QueueProducer | private |
_master_port (defined in slave::QueueProducer) | slave::QueueProducer | private |
_master_user (defined in slave::QueueProducer) | slave::QueueProducer | private |
_max_reconnects (defined in slave::QueueProducer) | slave::QueueProducer | private |
_saved_max_commit_id (defined in slave::QueueProducer) | slave::QueueProducer | private |
_seconds_between_reconnects (defined in slave::QueueProducer) | slave::QueueProducer | private |
_session (defined in slave::SQLExecutor) | slave::SQLExecutor | protected |
cachedMaxCommitId() (defined in slave::QueueProducer) | slave::QueueProducer | inline |
clearErrorState() (defined in slave::SQLExecutor) | slave::SQLExecutor | inline |
closeConnection() | slave::QueueProducer | private |
executeSQL(std::vector< std::string > &sql) | slave::SQLExecutor | |
getErrorMessage() const (defined in slave::SQLExecutor) | slave::SQLExecutor | inline |
getSleepInterval() (defined in slave::QueueProducer) | slave::QueueProducer | inlinevirtual |
init() | slave::QueueProducer | virtual |
markInErrorState() (defined in slave::SQLExecutor) | slave::SQLExecutor | inline |
masterId() (defined in slave::QueueProducer) | slave::QueueProducer | inline |
openConnection() | slave::QueueProducer | private |
process() | slave::QueueProducer | virtual |
queryForMaxCommitId(uint64_t *max_commit_id) | slave::QueueProducer | private |
queryForReplicationEvents(uint64_t max_commit_id) | slave::QueueProducer | private |
queryForTrxIdList(uint64_t max_commit_id, std::vector< uint64_t > &list) (defined in slave::QueueProducer) | slave::QueueProducer | private |
queueInsert(const char *trx_id, const char *seg_id, const char *commit_id, const char *originating_server_uuid, const char *originating_commit_id, const char *msg, const char *msg_length) (defined in slave::QueueProducer) | slave::QueueProducer | private |
QueueProducer() (defined in slave::QueueProducer) | slave::QueueProducer | inline |
reconnect(bool initial_connection) | slave::QueueProducer | private |
run(void) (defined in slave::QueueThread) | slave::QueueThread | |
setCachedMaxCommitId(uint64_t value) (defined in slave::QueueProducer) | slave::QueueProducer | inline |
setIOState(const std::string &err_msg, bool status) | slave::QueueProducer | private |
setMasterHost(const std::string &host) (defined in slave::QueueProducer) | slave::QueueProducer | inline |
setMasterId(uint32_t value) (defined in slave::QueueProducer) | slave::QueueProducer | inline |
setMasterPassword(const std::string &password) (defined in slave::QueueProducer) | slave::QueueProducer | inline |
setMasterPort(uint16_t port) (defined in slave::QueueProducer) | slave::QueueProducer | inline |
setMasterUser(const std::string &user) (defined in slave::QueueProducer) | slave::QueueProducer | inline |
setMaxReconnectAttempts(uint32_t max) (defined in slave::QueueProducer) | slave::QueueProducer | inline |
setSecondsBetweenReconnects(uint32_t seconds) (defined in slave::QueueProducer) | slave::QueueProducer | inline |
setSleepInterval(uint32_t seconds) (defined in slave::QueueProducer) | slave::QueueProducer | inline |
shutdown() | slave::QueueProducer | virtual |
SQLExecutor(const std::string &user, const std::string &schema) (defined in slave::SQLExecutor) | slave::SQLExecutor | |
~QueueProducer() (defined in slave::QueueProducer) | slave::QueueProducer | virtual |
~QueueThread() (defined in slave::QueueThread) | slave::QueueThread | inlinevirtual |