From 47a54036220fbcb9777967148f64dac3894e6add Mon Sep 17 00:00:00 2001
From: "Christoph Engelbert (noctarius)" <me@noctarius.com>
Date: Thu, 6 Jul 2023 17:57:55 +0200
Subject: [PATCH] Fixed type not implementing interface after refactoring

---
 .../replicationresolver.go                           |  4 ++--
 .../logicalreplicationresolver/transactiontracker.go | 12 ++++++++----
 2 files changed, 10 insertions(+), 6 deletions(-)

diff --git a/internal/replication/logicalreplicationresolver/replicationresolver.go b/internal/replication/logicalreplicationresolver/replicationresolver.go
index de9a5e32..363e4d38 100644
--- a/internal/replication/logicalreplicationresolver/replicationresolver.go
+++ b/internal/replication/logicalreplicationresolver/replicationresolver.go
@@ -75,11 +75,11 @@ func newLogicalReplicationResolver(config *spiconfig.Config, replicationContext
 	}, nil
 }
 
-func (l *logicalReplicationResolver) OnHypertableSnapshotStartedEvent(_ *spicatalog.Hypertable) error {
+func (l *logicalReplicationResolver) OnHypertableSnapshotStartedEvent(_ string, _ *spicatalog.Hypertable) error {
 	return nil
 }
 
-func (l *logicalReplicationResolver) OnHypertableSnapshotFinishedEvent(_ *spicatalog.Hypertable) error {
+func (l *logicalReplicationResolver) OnHypertableSnapshotFinishedEvent(_ string, _ *spicatalog.Hypertable) error {
 	return nil
 }
 
diff --git a/internal/replication/logicalreplicationresolver/transactiontracker.go b/internal/replication/logicalreplicationresolver/transactiontracker.go
index 7e514ab2..f7547564 100644
--- a/internal/replication/logicalreplicationresolver/transactiontracker.go
+++ b/internal/replication/logicalreplicationresolver/transactiontracker.go
@@ -65,12 +65,16 @@ func newTransactionTracker(timeout time.Duration, maxSize uint, replicationConte
 	}, nil
 }
 
-func (tt *transactionTracker) OnHypertableSnapshotStartedEvent(hypertable *spicatalog.Hypertable) error {
-	return tt.resolver.OnHypertableSnapshotStartedEvent(hypertable)
+func (tt *transactionTracker) OnHypertableSnapshotStartedEvent(
+	snapshotName string, hypertable *spicatalog.Hypertable) error {
+
+	return tt.resolver.OnHypertableSnapshotStartedEvent(snapshotName, hypertable)
 }
 
-func (tt *transactionTracker) OnHypertableSnapshotFinishedEvent(hypertable *spicatalog.Hypertable) error {
-	return tt.resolver.OnHypertableSnapshotFinishedEvent(hypertable)
+func (tt *transactionTracker) OnHypertableSnapshotFinishedEvent(
+	snapshotName string, hypertable *spicatalog.Hypertable) error {
+
+	return tt.resolver.OnHypertableSnapshotFinishedEvent(snapshotName, hypertable)
 }
 
 func (tt *transactionTracker) OnSnapshottingStartedEvent(snapshotName string) error {