diff options
Diffstat (limited to 'lib/input/replStream.h')
| -rw-r--r-- | lib/input/replStream.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/lib/input/replStream.h b/lib/input/replStream.h index 40ec390..4958459 100644 --- a/lib/input/replStream.h +++ b/lib/input/replStream.h @@ -3,6 +3,7 @@ #include "mysqlConn.h" #include <cstdint> +#include <eventCounter.h> #include <eventSourceBase.h> #include <string> @@ -19,10 +20,14 @@ namespace MyGrate::Input { void readEvents(EventHandlerBase &) override; void stopEvents() override; + const EventCounter & getReceivedCounts() const; + const EventCounter & getHandledCounts() const; + private: uint64_t serverid; std::string filename; uint64_t position; + EventCounter received, handled; }; } |