Drizzled Public API Documentation

slave::QueueConsumer Member List

This is the complete list of members for slave::QueueConsumer, including all inherited members.

_check_intervalslave::QueueConsumerprivate
_ignore_errors (defined in slave::QueueConsumer)slave::QueueConsumerprivate
_master_ids (defined in slave::QueueConsumer)slave::QueueConsumerprivate
_session (defined in slave::SQLExecutor)slave::SQLExecutorprotected
addMasterId(uint32_t id) (defined in slave::QueueConsumer)slave::QueueConsumerinline
clearErrorState() (defined in slave::SQLExecutor)slave::SQLExecutorinline
convertToSQL(const drizzled::message::Transaction &transaction, std::vector< std::string > &aggregate_sql, std::vector< std::string > &segmented_sql)slave::QueueConsumerprivate
deleteFromQueue(const std::string &master_id, uint64_t trx_id)slave::QueueConsumerprivate
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::QueueConsumerprivate
getErrorMessage() const (defined in slave::SQLExecutor)slave::SQLExecutorinline
getListOfCompletedTransactions(const std::string &master_id, TrxIdList &list)slave::QueueConsumerprivate
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::QueueConsumerprivate
getSleepInterval() (defined in slave::QueueConsumer)slave::QueueConsumerinlinevirtual
init()slave::QueueConsumervirtual
isEndStatement(const drizzled::message::Statement &statement)slave::QueueConsumerprivate
markInErrorState() (defined in slave::SQLExecutor)slave::SQLExecutorinline
process()slave::QueueConsumervirtual
processSingleMaster(const std::string &master_id) (defined in slave::QueueConsumer)slave::QueueConsumer
QueueConsumer() (defined in slave::QueueConsumer)slave::QueueConsumerinline
run(void) (defined in slave::QueueThread)slave::QueueThread
setApplierState(const std::string &err_msg, bool status)slave::QueueConsumer
setIgnoreErrors(bool value)slave::QueueConsumerinline
setSleepInterval(uint32_t seconds) (defined in slave::QueueConsumer)slave::QueueConsumerinline
shutdown()slave::QueueConsumervirtual
SQLExecutor(const std::string &user, const std::string &schema) (defined in slave::SQLExecutor)slave::SQLExecutor
TrxIdList typedef (defined in slave::QueueConsumer)slave::QueueConsumerprivate
~QueueThread() (defined in slave::QueueThread)slave::QueueThreadinlinevirtual