lib/input/replStream.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

#ifndef MYGRATE_INPUT_REPLSTREAM_H
#define MYGRATE_INPUT_REPLSTREAM_H

#include "../eventSourceBase.h"
#include "mysqlConn.h"

namespace MyGrate::Input {
	class ReplicationStream : public EventSourceBase, MySQLConn {
	public:
		using MySQLConn::MySQLConn;

		void readEvents(EventHandlerBase &) override;
	};
}

#endif