This is the complete list of members for slave::QueueConsumer, including all inherited members.
_check_interval | slave::QueueConsumer | private |
_ignore_errors (defined in slave::QueueConsumer) | slave::QueueConsumer | private |
_master_ids (defined in slave::QueueConsumer) | slave::QueueConsumer | private |
_session (defined in slave::SQLExecutor) | slave::SQLExecutor | protected |
addMasterId(uint32_t id) (defined in slave::QueueConsumer) | slave::QueueConsumer | inline |
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(const std::string &master_id, 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, const std::string &originating_server_uuid, uint64_t originating_commit_id, const std::string &master_id) | slave::QueueConsumer | private |
getErrorMessage() const (defined in slave::SQLExecutor) | slave::SQLExecutor | inline |
getListOfCompletedTransactions(const std::string &master_id, TrxIdList &list) | slave::QueueConsumer | private |
getMessage(drizzled::message::Transaction &transaction, std::string &commit_id, const std::string &master_id, uint64_t trx_id, std::string &originating_server_uuid, uint64_t &originating_commit_id, uint32_t segment_id) (defined in slave::QueueConsumer) | slave::QueueConsumer | private |
getSleepInterval() (defined in slave::QueueConsumer) | slave::QueueConsumer | inlinevirtual |
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 |
processSingleMaster(const std::string &master_id) (defined in slave::QueueConsumer) | slave::QueueConsumer | |
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 | |
setIgnoreErrors(bool value) | slave::QueueConsumer | inline |
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 | inlinevirtual |