diff --git a/internal/replication/replicationconnection/replicationconnection_test.go b/internal/replication/replicationconnection/replicationconnection_test.go index 13fe7f29..198cb167 100644 --- a/internal/replication/replicationconnection/replicationconnection_test.go +++ b/internal/replication/replicationconnection/replicationconnection_test.go @@ -486,3 +486,7 @@ func (t testReplicationContext) ReadReplicationSlot( return t.readReplicationSlot(slotName) } + +func (t testReplicationContext) IsDecompressionMarkingEnabled() bool { + return false +}