From 9592817df3dd98814c5ae0845dd1617ac20d774d Mon Sep 17 00:00:00 2001
From: Dan Goodliffe <dan@randomdan.homeip.net>
Date: Sun, 25 Jul 2021 12:45:15 +0100
Subject: Add before/after event to update position in replication stream

---
 lib/output/pq/updateDatabase.h | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'lib/output/pq/updateDatabase.h')

diff --git a/lib/output/pq/updateDatabase.h b/lib/output/pq/updateDatabase.h
index 970c6d5..9547b90 100644
--- a/lib/output/pq/updateDatabase.h
+++ b/lib/output/pq/updateDatabase.h
@@ -66,6 +66,9 @@ namespace MyGrate::Output::Pq {
 		UpdateDatabase(PqConn &&, uint64_t source);
 		UpdateDatabase(PqConn &&, uint64_t source, RecordSetPtr cfg);
 
+		void beforeEvent(const MariaDB_Event_Ptr & e);
+		void afterEvent(const MariaDB_Event_Ptr & e);
+
 		static void verifyRow(const MariaDB_Event_Ptr & e, const TableDefPtr &);
 		static void copyAll(const Row & r, std::back_insert_iterator<std::vector<DbValue>> &&);
 		static void copyKeys(const Row & r, const TableDefPtr &, std::back_insert_iterator<std::vector<DbValue>> &&);
-- 
cgit v1.2.3