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