Mirrors/coredns
1
0
Fork 0
mirror of https://github.com/coredns/coredns.git synced 2025-11-01 02:33:14 -04:00
Code Issues Packages Projects Releases Wiki Activity

update informer for client-go 0.27 (#6038)

Browse Source 
Signed-off-by: Chris O'Haver <cohaver@infoblox.com>
This commit is contained in:
Chris O'Haver
2023-04-20 13:24:06 -04:00
committed by GitHub
parent 7be03b6aeb
commit 68816a42a7
5 changed files with 49 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
plugin/kubernetes/controller_test.go
View File

@@ -1,4 +1,4 @@
package kubernetes
package kubernetes
import (
"context"

8
plugin/kubernetes/informer_test.go
View File

@@ -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)
}

4
plugin/kubernetes/object/informer.go
View File

@@ -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()