summaryrefslogtreecommitdiff
path: root/lib/input/replStream.h
diff options
context:
space:
mode:
Diffstat (limited to 'lib/input/replStream.h')
-rw-r--r--lib/input/replStream.h10
1 files changed, 9 insertions, 1 deletions
diff --git a/lib/input/replStream.h b/lib/input/replStream.h
index 4b1a7b6..01c9ef3 100644
--- a/lib/input/replStream.h
+++ b/lib/input/replStream.h
@@ -2,7 +2,9 @@
#define MYGRATE_INPUT_REPLSTREAM_H
#include "mysqlConn.h"
+#include <cstdint>
#include <eventSourceBase.h>
+#include <string>
namespace MyGrate {
class EventHandlerBase;
@@ -11,9 +13,15 @@ namespace MyGrate {
namespace MyGrate::Input {
class ReplicationStream : public EventSourceBase, MySQLConn {
public:
- using MySQLConn::MySQLConn;
+ ReplicationStream(const char * const host, const char * const user, const char * const pass,
+ unsigned short port, uint64_t serverid, std::string filename, uint64_t position);
void readEvents(EventHandlerBase &) override;
+
+ private:
+ uint64_t serverid;
+ std::string filename;
+ uint64_t position;
};
}