Drizzled Public API Documentation

slave::QueueProducer Member List

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

_check_intervalslave::QueueProducerprivate
_connection (defined in slave::QueueProducer)slave::QueueProducerprivate
_drizzle (defined in slave::QueueProducer)slave::QueueProducerprivate
_is_connected (defined in slave::QueueProducer)slave::QueueProducerprivate
_last_error_message (defined in slave::QueueProducer)slave::QueueProducerprivate
_last_return (defined in slave::QueueProducer)slave::QueueProducerprivate
_master_host (defined in slave::QueueProducer)slave::QueueProducerprivate
_master_id (defined in slave::QueueProducer)slave::QueueProducerprivate
_master_pass (defined in slave::QueueProducer)slave::QueueProducerprivate
_master_port (defined in slave::QueueProducer)slave::QueueProducerprivate
_master_user (defined in slave::QueueProducer)slave::QueueProducerprivate
_max_reconnects (defined in slave::QueueProducer)slave::QueueProducerprivate
_saved_max_commit_id (defined in slave::QueueProducer)slave::QueueProducerprivate
_seconds_between_reconnects (defined in slave::QueueProducer)slave::QueueProducerprivate
_session (defined in slave::SQLExecutor)slave::SQLExecutorprotected
cachedMaxCommitId() (defined in slave::QueueProducer)slave::QueueProducerinline
clearErrorState() (defined in slave::SQLExecutor)slave::SQLExecutorinline
closeConnection()slave::QueueProducerprivate
executeSQL(std::vector< std::string > &sql)slave::SQLExecutor
getErrorMessage() const (defined in slave::SQLExecutor)slave::SQLExecutorinline
getSleepInterval() (defined in slave::QueueProducer)slave::QueueProducerinlinevirtual
init()slave::QueueProducervirtual
markInErrorState() (defined in slave::SQLExecutor)slave::SQLExecutorinline
masterId() (defined in slave::QueueProducer)slave::QueueProducerinline
openConnection()slave::QueueProducerprivate
process()slave::QueueProducervirtual
queryForMaxCommitId(uint64_t *max_commit_id)slave::QueueProducerprivate
queryForReplicationEvents(uint64_t max_commit_id)slave::QueueProducerprivate
queryForTrxIdList(uint64_t max_commit_id, std::vector< uint64_t > &list) (defined in slave::QueueProducer)slave::QueueProducerprivate
queueInsert(const char *trx_id, const char *seg_id, const char *commit_id, const char *originating_server_uuid, const char *originating_commit_id, const char *msg, const char *msg_length) (defined in slave::QueueProducer)slave::QueueProducerprivate
QueueProducer() (defined in slave::QueueProducer)slave::QueueProducerinline
reconnect(bool initial_connection)slave::QueueProducerprivate
run(void) (defined in slave::QueueThread)slave::QueueThread
setCachedMaxCommitId(uint64_t value) (defined in slave::QueueProducer)slave::QueueProducerinline
setIOState(const std::string &err_msg, bool status)slave::QueueProducerprivate
setMasterHost(const std::string &host) (defined in slave::QueueProducer)slave::QueueProducerinline
setMasterId(uint32_t value) (defined in slave::QueueProducer)slave::QueueProducerinline
setMasterPassword(const std::string &password) (defined in slave::QueueProducer)slave::QueueProducerinline
setMasterPort(uint16_t port) (defined in slave::QueueProducer)slave::QueueProducerinline
setMasterUser(const std::string &user) (defined in slave::QueueProducer)slave::QueueProducerinline
setMaxReconnectAttempts(uint32_t max) (defined in slave::QueueProducer)slave::QueueProducerinline
setSecondsBetweenReconnects(uint32_t seconds) (defined in slave::QueueProducer)slave::QueueProducerinline
setSleepInterval(uint32_t seconds) (defined in slave::QueueProducer)slave::QueueProducerinline
shutdown()slave::QueueProducervirtual
SQLExecutor(const std::string &user, const std::string &schema) (defined in slave::SQLExecutor)slave::SQLExecutor
~QueueProducer() (defined in slave::QueueProducer)slave::QueueProducervirtual
~QueueThread() (defined in slave::QueueThread)slave::QueueThreadinlinevirtual