diff options
| author |  Chris O'Haver <cohaver@infoblox.com>
| 2020-12-01 15:29:05 -0500 |
|---|---|---|
| committer |  GitHub <noreply@github.com>
| 2020-12-01 15:29:05 -0500 |
| commit | 9121e784966d52bb93696d83d9ab394ac2efd77d (patch) | |
| tree | c9d6c6ac28f712116eaec06a72119fc709d8e849 /plugin/kubernetes/informer_test.go | |
| parent | 56eea6e6099c41e8913b6c24fbbc156133f22c62 (diff) | |
| download | coredns-9121e784966d52bb93696d83d9ab394ac2efd77d.tar.gz coredns-9121e784966d52bb93696d83d9ab394ac2efd77d.tar.zst coredns-9121e784966d52bb93696d83d9ab394ac2efd77d.zip | |
plugin/kubernetes: Fix dns programming duration metric (#4255)
* get data reqd to record latency before calling toFuncs
* refactor out unnecessary toFunc wrappers
* remove latency metric unit tests per PR feedback
Signed-off-by: Chris O'Haver <cohaver@infoblox.com>
Diffstat (limited to 'plugin/kubernetes/informer_test.go')
| -rw-r--r-- | plugin/kubernetes/informer_test.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/plugin/kubernetes/informer_test.go b/plugin/kubernetes/informer_test.go index 5156554e9..7aa9d1e83 100644 --- a/plugin/kubernetes/informer_test.go +++ b/plugin/kubernetes/informer_test.go @@ -11,7 +11,7 @@ import ( ) func TestDefaultProcessor(t *testing.T) { - pbuild := object.DefaultProcessor(object.ToService(true), nil) + pbuild := object.DefaultProcessor(object.ToService, nil) reh := cache.ResourceEventHandlerFuncs{} idx := cache.NewIndexer(cache.DeletionHandlingMetaNamespaceKeyFunc, cache.Indexers{}) processor := pbuild(idx, reh) @@ -30,8 +30,8 @@ func testProcessor(t *testing.T, processor cache.ProcessFunc, idx cache.Indexer) // Add the objects err := processor(cache.Deltas{ - {Type: cache.Added, Object: obj}, - {Type: cache.Added, Object: obj2}, + {Type: cache.Added, Object: obj.DeepCopy()}, + {Type: cache.Added, Object: obj2.DeepCopy()}, }) if err != nil { t.Fatalf("add failed: %v", err) @@ -55,7 +55,7 @@ func testProcessor(t *testing.T, processor cache.ProcessFunc, idx cache.Indexer) obj.Spec.ClusterIP = "1.2.3.5" err = processor(cache.Deltas{{ Type: cache.Updated, - Object: obj, + Object: obj.DeepCopy(), }}) if err != nil { t.Fatalf("update failed: %v", err) @@ -78,7 +78,7 @@ func testProcessor(t *testing.T, processor cache.ProcessFunc, idx cache.Indexer) // Delete an object err = processor(cache.Deltas{{ Type: cache.Deleted, - Object: obj2, + Object: obj2.DeepCopy(), }}) if err != nil { t.Fatalf("delete test failed: %v", err) |