diff --git a/provider/cached_provider_test.go b/provider/cached_provider_test.go
index 2c7eec95aa..4e358066fa 100644
--- a/provider/cached_provider_test.go
+++ b/provider/cached_provider_test.go
@@ -17,6 +17,7 @@ package provider
 
 import (
 	"context"
+	"errors"
 	"testing"
 	"time"
 
@@ -30,7 +31,7 @@ type testProviderFunc struct {
 	records             func(ctx context.Context) ([]*endpoint.Endpoint, error)
 	applyChanges        func(ctx context.Context, changes *plan.Changes) error
 	propertyValuesEqual func(name string, previous string, current string) bool
-	adjustEndpoints     func(endpoints []*endpoint.Endpoint) []*endpoint.Endpoint
+	adjustEndpoints     func(endpoints []*endpoint.Endpoint) ([]*endpoint.Endpoint, error)
 	getDomainFilter     func() endpoint.DomainFilterInterface
 }
 
@@ -46,7 +47,7 @@ func (p *testProviderFunc) PropertyValuesEqual(name string, previous string, cur
 	return p.propertyValuesEqual(name, previous, current)
 }
 
-func (p *testProviderFunc) AdjustEndpoints(endpoints []*endpoint.Endpoint) []*endpoint.Endpoint {
+func (p *testProviderFunc) AdjustEndpoints(endpoints []*endpoint.Endpoint) ([]*endpoint.Endpoint, error) {
 	return p.adjustEndpoints(endpoints)
 }
 
@@ -75,10 +76,10 @@ func propertyValuesEqualNotCalled(t *testing.T) func(name string, previous strin
 	}
 }
 
-func adjustEndpointsNotCalled(t *testing.T) func(endpoints []*endpoint.Endpoint) []*endpoint.Endpoint {
-	return func(endpoints []*endpoint.Endpoint) []*endpoint.Endpoint {
+func adjustEndpointsNotCalled(t *testing.T) func(endpoints []*endpoint.Endpoint) ([]*endpoint.Endpoint, error) {
+	return func(endpoints []*endpoint.Endpoint) ([]*endpoint.Endpoint, error) {
 		t.Errorf("unexpected call to AdjustEndpoints")
-		return endpoints
+		return endpoints, errors.New("unexpected call to AdjustEndpoints")
 	}
 }
 
diff --git a/provider/webhook/api/httpapi_test.go b/provider/webhook/api/httpapi_test.go
index 48685dc9d9..a15efec471 100644
--- a/provider/webhook/api/httpapi_test.go
+++ b/provider/webhook/api/httpapi_test.go
@@ -62,7 +62,7 @@ func (p FakeWebhookProvider) AdjustEndpoints(endpoints []*endpoint.Endpoint) ([]
 	return endpoints, nil
 }
 
-func (p FakeWebhookProvider) GetDomainFilter() endpoint.DomainFilter {
+func (p FakeWebhookProvider) GetDomainFilter() endpoint.DomainFilterInterface {
 	return p.domainFilter
 }
 
diff --git a/provider/webhook/webhook.go b/provider/webhook/webhook.go
index d504842900..8cae0850e2 100644
--- a/provider/webhook/webhook.go
+++ b/provider/webhook/webhook.go
@@ -296,7 +296,7 @@ func (p WebhookProvider) AdjustEndpoints(e []*endpoint.Endpoint) ([]*endpoint.En
 }
 
 // GetDomainFilter make calls to get the serialized version of the domain filter
-func (p WebhookProvider) GetDomainFilter() endpoint.DomainFilter {
+func (p WebhookProvider) GetDomainFilter() endpoint.DomainFilterInterface {
 	return p.DomainFilter
 }