Fixed type not implementing interface after refactoring

noctarius · Jul 6, 2023 · 47a5403 · 47a5403
1 parent d1c3926
commit 47a5403
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 6 deletions.
diff --git 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
@@ -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 {