_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_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] |
clearErrorState() (defined in slave::SQLExecutor) | slave::SQLExecutor | [inline] |
closeConnection() | slave::QueueProducer | [private] |
executeSQL(std::vector< std::string > &sql) | slave::SQLExecutor | |
getErrorMessage() (defined in slave::SQLExecutor) | slave::SQLExecutor | [inline] |
getSleepInterval() (defined in slave::QueueProducer) | slave::QueueProducer | [inline, virtual] |
init() | slave::QueueProducer | [virtual] |
markInErrorState() (defined in slave::SQLExecutor) | slave::SQLExecutor | [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 *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] |
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 | [inline, virtual] |