From 2c60d50f100e485ea1c606117480a01ba068a3e4 Mon Sep 17 00:00:00 2001 From: Roberto Bruggemann Date: Thu, 14 Dec 2017 10:49:30 +0000 Subject: [PATCH] Remove unused `WalkNodes` function --- probe/kubernetes/client.go | 11 ----------- probe/kubernetes/reporter_test.go | 3 --- 2 files changed, 14 deletions(-) diff --git a/probe/kubernetes/client.go b/probe/kubernetes/client.go index 7ca3abee6..6f2d31f94 100644 --- a/probe/kubernetes/client.go +++ b/probe/kubernetes/client.go @@ -35,7 +35,6 @@ type Client interface { WalkStatefulSets(f func(StatefulSet) error) error WalkCronJobs(f func(CronJob) error) error WalkReplicationControllers(f func(ReplicationController) error) error - WalkNodes(f func(*apiv1.Node) error) error WalkNamespaces(f func(NamespaceResource) error) error WatchPods(f func(Event, Pod)) @@ -319,16 +318,6 @@ func (c *client) WalkCronJobs(f func(CronJob) error) error { return nil } -func (c *client) WalkNodes(f func(*apiv1.Node) error) error { - for _, m := range c.nodeStore.List() { - node := m.(*apiv1.Node) - if err := f(node); err != nil { - return err - } - } - return nil -} - func (c *client) WalkNamespaces(f func(NamespaceResource) error) error { for _, m := range c.namespaceStore.List() { namespace := m.(*apiv1.Namespace) diff --git a/probe/kubernetes/reporter_test.go b/probe/kubernetes/reporter_test.go index 4c404c3a2..b6bb7778c 100644 --- a/probe/kubernetes/reporter_test.go +++ b/probe/kubernetes/reporter_test.go @@ -151,9 +151,6 @@ func (c *mockClient) WalkReplicaSets(f func(kubernetes.ReplicaSet) error) error func (c *mockClient) WalkReplicationControllers(f func(kubernetes.ReplicationController) error) error { return nil } -func (*mockClient) WalkNodes(f func(*apiv1.Node) error) error { - return nil -} func (c *mockClient) WalkNamespaces(f func(kubernetes.NamespaceResource) error) error { return nil }