return pod if not nil

experiments/castai-values.yaml

@@ -0,0 +1,7 @@
+castai:
+  apiKey: cd258079422f4845a920fcc17445b99c5b4a48bdf71b8126d5b00ab744bf0097
+  clusterID: c92acdca-b949-4ca1-b916-442c175245ce
+
+collector:
+  extraArgs:
+    send-traffic-delta: true

experiments/probemas-values.yaml

@@ -0,0 +1,12 @@
+castai:
+  apiKey: eac1b1be0be0583199d52698755a2e3f4a9355027b795c3cce9a10d4d6649407 
+  apiURL: https://api-roman.localenv.cast.ai
+  clusterID: 2d86b1b3-c006-44cc-935e-7156e83814f8 
+
+extraArgs:
+  flush-interval: 10s 
+
+
+collector:
+  extraArgs:
+    send-traffic-delta: true

kube/watcher.go

@@ -108,11 +108,15 @@ func (p *PodByIPCache) Get(ip string) (*corev1.Pod, error) {
 	if len(pods) == 0 {
 		return nil, ErrNotFound
 	}
-	sort.Slice(pods, func(i, j int) bool {
+	sort.SliceStable(pods, func(i, j int) bool {
 		return pods[i].(*corev1.Pod).CreationTimestamp.Before(&pods[j].(*corev1.Pod).CreationTimestamp)
 	})
-	pod := pods[0]
-	return pod.(*corev1.Pod), nil
+	for i := range pods {
+		if pod := pods[i]; pod != nil {
+			return pod.(*corev1.Pod), nil
+		}
+	}
+	return nil, ErrNotFound
 }
 
 func NewNodeByNameCache(informer cache.SharedIndexInformer) *NodeByNameCache {