Drizzled Public API Documentation

slave::QueueProducer Member List
This is the complete list of members for slave::QueueProducer, including all inherited members.
_check_intervalslave::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]