update informer for client-go 0.27 (#6038)

Signed-off-by: Chris O'Haver <cohaver@infoblox.com>

3 files changed, 7 insertions, 7 deletions

diff --git a/plugin/kubernetes/controller_test.go b/plugin/kubernetes/controller_test.go
index 469eb59b6..8f906e0c8 100644
--- a/plugin/kubernetes/controller_test.go
+++ b/plugin/kubernetes/controller_test.go
@@ -1,4 +1,4 @@
-package kubernetes
+ package kubernetes
 
 import (
 	"context"
diff --git a/plugin/kubernetes/informer_test.go b/plugin/kubernetes/informer_test.go
index ae68b5cfe..ee5186a94 100644
--- a/plugin/kubernetes/informer_test.go
+++ b/plugin/kubernetes/informer_test.go
@@ -41,7 +41,7 @@ func testProcessor(t *testing.T, processor cache.ProcessFunc, idx cache.Indexer)
 	err := processor(cache.Deltas{
 		{Type: cache.Added, Object: obj.DeepCopy()},
 		{Type: cache.Added, Object: obj2.DeepCopy()},
-	})
+	}, false)
 	if err != nil {
 		t.Fatalf("add failed: %v", err)
 	}
@@ -65,7 +65,7 @@ func testProcessor(t *testing.T, processor cache.ProcessFunc, idx cache.Indexer)
 	err = processor(cache.Deltas{{
 		Type:   cache.Updated,
 		Object: obj.DeepCopy(),
-	}})
+	}}, false)
 	if err != nil {
 		t.Fatalf("update failed: %v", err)
 	}
@@ -88,7 +88,7 @@ func testProcessor(t *testing.T, processor cache.ProcessFunc, idx cache.Indexer)
 	err = processor(cache.Deltas{{
 		Type:   cache.Deleted,
 		Object: obj2.DeepCopy(),
-	}})
+	}}, false)
 	if err != nil {
 		t.Fatalf("delete test failed: %v", err)
 	}
@@ -106,7 +106,7 @@ func testProcessor(t *testing.T, processor cache.ProcessFunc, idx cache.Indexer)
 	err = processor(cache.Deltas{{
 		Type:   cache.Deleted,
 		Object: tombstone,
-	}})
+	}}, false)
 	if err != nil {
 		t.Fatalf("tombstone delete test failed: %v", err)
 	}
diff --git a/plugin/kubernetes/object/informer.go b/plugin/kubernetes/object/informer.go
index aac95bd8b..86d872cd2 100644
--- a/plugin/kubernetes/object/informer.go
+++ b/plugin/kubernetes/object/informer.go
@@ -29,7 +29,7 @@ type RecordLatencyFunc func(meta.Object)
 // DefaultProcessor is based on the Process function from cache.NewIndexerInformer except it does a conversion.
 func DefaultProcessor(convert ToFunc, recordLatency *EndpointLatencyRecorder) ProcessorBuilder {
 	return func(clientState cache.Indexer, h cache.ResourceEventHandler) cache.ProcessFunc {
-		return func(obj interface{}) error {
+		return func(obj interface{}, isInitialList bool) error {
 			for _, d := range obj.(cache.Deltas) {
 				if recordLatency != nil {
 					if o, ok := d.Object.(meta.Object); ok {
@@ -51,7 +51,7 @@ func DefaultProcessor(convert ToFunc, recordLatency *EndpointLatencyRecorder) Pr
 						if err := clientState.Add(obj); err != nil {
 							return err
 						}
-						h.OnAdd(obj)
+						h.OnAdd(obj, isInitialList)
 					}
 					if recordLatency != nil {
 						recordLatency.record()