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] |