23 #include <plugin/slave/queue_thread.h>
24 #include <plugin/slave/sql_executor.h>
25 #include <drizzled/session.h>
53 void setSleepInterval(uint32_t seconds)
58 uint32_t getSleepInterval()
68 _ignore_errors= value;
79 void addMasterId(uint32_t
id)
81 _master_ids.push_back(
id);
84 bool processSingleMaster(
const std::string &master_id);
87 typedef std::vector<uint64_t> TrxIdList;
92 std::vector<uint32_t> _master_ids;
112 std::string &commit_id,
113 const std::string &master_id,
115 std::string &originating_server_uuid,
116 uint64_t &originating_commit_id,
117 uint32_t segment_id);
130 std::vector<std::string> &aggregate_sql,
131 std::vector<std::string> &segmented_sql);
147 const std::string &commit_id,
148 const std::string &originating_server_uuid,
149 uint64_t originating_commit_id,
150 const std::string &master_id);