diff --git a/metadata/fake/simple.go b/metadata/fake/simple.go index 47beb1f8d..fc50113fc 100644 --- a/metadata/fake/simple.go +++ b/metadata/fake/simple.go @@ -109,6 +109,10 @@ func (c *FakeMetadataClient) Resource(resource schema.GroupVersionResource) meta return &metadataResourceClient{client: c, resource: resource} } +func (c *FakeMetadataClient) IsWatchListSemanticsUnSupported() bool { + return true +} + // Namespace returns an interface for accessing the current resource in the specified // namespace. func (c *metadataResourceClient) Namespace(ns string) metadata.ResourceInterface { diff --git a/metadata/fake/simple_test.go b/metadata/fake/simple_test.go index a8369f9f1..d20a8a265 100644 --- a/metadata/fake/simple_test.go +++ b/metadata/fake/simple_test.go @@ -27,6 +27,7 @@ import ( "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/types" + "k8s.io/client-go/util/watchlist" ) const ( @@ -58,6 +59,13 @@ func newPartialObjectMetadataWithAnnotations(annotations map[string]string) *met return u } +func TestDoesClientSupportWatchListSemantics(t *testing.T) { + target := &FakeMetadataClient{} + if !watchlist.DoesClientNotSupportWatchListSemantics(target) { + t.Fatalf("FakeMetadataClient should NOT support WatchList semantics") + } +} + func TestList(t *testing.T) { scheme := NewTestScheme() metav1.AddMetaToScheme(scheme)