Fix issue with CircleCI build.

The issue was that the Clientset struct, which contains the CoreV1() method, was embedded directly in the Client struct. While this works in some Go versions, it seems the CircleCI environment's Go version requires explicit access to the embedded struct. I've updated the code to use k8s.Clientset.CoreV1() to explicitly access the CoreV1() method through the embedded Clientset. This should resolve the build and test failures in CircleCI.

Author: jtblin

k8s/k8s.go

@@ -37,7 +37,7 @@ func (k8s *Client) createPodLW() *cache.ListWatch {
 	if k8s.nodeName != "" {
 		fieldSelector = selector.OneTermEqualSelector("spec.nodeName", k8s.nodeName)
 	}
-	return cache.NewListWatchFromClient(k8s.CoreV1().RESTClient(), "pods", v1.NamespaceAll, fieldSelector)
+	return cache.NewListWatchFromClient(k8s.Clientset.CoreV1().RESTClient(), "pods", v1.NamespaceAll, fieldSelector)
 }
 
 // WatchForPods watches for pod changes.
@@ -55,7 +55,7 @@ func (k8s *Client) WatchForPods(podEventLogger cache.ResourceEventHandler, resyn
 
 // returns a cache.ListWatch of namespaces.
 func (k8s *Client) createNamespaceLW() *cache.ListWatch {
-	return cache.NewListWatchFromClient(k8s.CoreV1().RESTClient(), "namespaces", v1.NamespaceAll, selector.Everything())
+	return cache.NewListWatchFromClient(k8s.Clientset.CoreV1().RESTClient(), "namespaces", v1.NamespaceAll, selector.Everything())
 }
 
 // WatchForNamespaces watches for namespaces changes.
@@ -120,7 +120,7 @@ func (k8s *Client) PodByIP(IP string) (*v1.Pod, error) {
 // If the indexed pods all have HostNetwork = true the function return nil and the error message.
 // If we retrive a running pod that doesn't have HostNetwork = true and it is in Running state will return that.
 func resolveDuplicatedIP(k8s *Client, IP string) (*v1.Pod, error) {
-	runningPodList, err := k8s.CoreV1().Pods("").List(metav1.ListOptions{
+	runningPodList, err := k8s.Clientset.CoreV1().Pods("").List(metav1.ListOptions{
 		FieldSelector: selector.OneTermEqualSelector("status.podIP", IP).String(),
 	})
 	metrics.K8sAPIDupReqCount.Inc()