Drizzled Public API Documentation

slave::QueueConsumer Member List

This is the complete list of members for slave::QueueConsumer, including all inherited members.
_check_intervalslave::QueueConsumer [private]
_session (defined in slave::SQLExecutor)slave::SQLExecutor [protected]
clearErrorState() (defined in slave::SQLExecutor)slave::SQLExecutor [inline]
convertToSQL(const drizzled::message::Transaction &transaction, std::vector< std::string > &aggregate_sql, std::vector< std::string > &segmented_sql)slave::QueueConsumer [private]
deleteFromQueue(uint64_t trx_id)slave::QueueConsumer [private]
executeSQL(std::vector< std::string > &sql)slave::SQLExecutor
executeSQLWithCommitId(std::vector< std::string > &sql, const std::string &commit_id)slave::QueueConsumer [private]
getErrorMessage() (defined in slave::SQLExecutor)slave::SQLExecutor [inline]
getListOfCompletedTransactions(TrxIdList &list) (defined in slave::QueueConsumer)slave::QueueConsumer [private]
getMessage(drizzled::message::Transaction &transaction, std::string &commit_id, uint64_t trx_id, uint32_t segment_id) (defined in slave::QueueConsumer)slave::QueueConsumer [private]
getSleepInterval() (defined in slave::QueueConsumer)slave::QueueConsumer [inline, virtual]
init()slave::QueueConsumer [virtual]
isEndStatement(const drizzled::message::Statement &statement)slave::QueueConsumer [private]
markInErrorState() (defined in slave::SQLExecutor)slave::SQLExecutor [inline]
process()slave::QueueConsumer [virtual]
QueueConsumer() (defined in slave::QueueConsumer)slave::QueueConsumer [inline]
run(void) (defined in slave::QueueThread)slave::QueueThread
setApplierState(const std::string &err_msg, bool status)slave::QueueConsumer
setSleepInterval(uint32_t seconds) (defined in slave::QueueConsumer)slave::QueueConsumer [inline]
shutdown()slave::QueueConsumer [virtual]
SQLExecutor(const std::string &user, const std::string &schema) (defined in slave::SQLExecutor)slave::SQLExecutor
TrxIdList typedef (defined in slave::QueueConsumer)slave::QueueConsumer [private]
~QueueThread() (defined in slave::QueueThread)slave::QueueThread [inline, virtual]