Optionally use Readiness in GetAll Pods.

pkg/goldpinger/config.go

@@ -38,6 +38,8 @@ var GoldpingerConfig = struct {
 	DisplayNodeName  bool    `long:"display-nodename" description:"Display nodename other than podname in UI (defaults is podname)." env:"DISPLAY_NODENAME"`
 	KubernetesClient *kubernetes.Clientset
 
+	UseReadiness bool `long:"use-readiness" description:"Use readiness probes to determine if a pod is ready (defaults to false which relies just on running)." env:"USE_READINESS"`
+
 	DnsHosts    []string `long:"host-to-resolve" description:"A host to attempt dns resolve on (space delimited)" env:"HOSTS_TO_RESOLVE" env-delim:" "`
 	TCPTargets  []string `long:"tcp-targets" description:"A list of external targets(<host>:<port> or <ip>:<port>) to attempt a TCP check on (space delimited)" env:"TCP_TARGETS" env-delim:" "`
 	HTTPTargets []string `long:"http-targets" description:"A list of external targets(<http or https>://<url>) to attempt an HTTP{S} check on. A 200 HTTP code is considered successful.(space delimited)" env:"HTTP_TARGETS" env-delim:" "`

pkg/goldpinger/k8s.go

@@ -103,6 +103,17 @@ func getPodNodeName(p v1.Pod) string {
 	return p.Name
 }
 
+// isReady is equivalent to k8s.io/kubectl/pkg/util/podutils.IsPodReady" but that brings us up a go version
+// if we don't mind those dependencies could replace.
+func isReady(pod *v1.Pod) bool {
+	for _, cond := range pod.Status.Conditions {
+		if cond.Type == v1.PodReady && cond.Status == v1.ConditionTrue {
+			return true
+		}
+	}
+	return false
+}
+
 // GetAllPods returns a mapping from a pod name to a pointer to a GoldpingerPod(s)
 func GetAllPods() map[string]*GoldpingerPod {
 	timer := GetLabeledKubernetesCallsTimer()
@@ -122,6 +133,12 @@ func GetAllPods() map[string]*GoldpingerPod {
 
 	podMap := make(map[string]*GoldpingerPod)
 	for _, pod := range pods.Items {
+		if GoldpingerConfig.UseReadiness {
+			if !isReady(&pod) {
+				continue
+			}
+		}
+
 		podMap[pod.Name] = &GoldpingerPod{
 			Name:   getPodNodeName(pod),
 			PodIP:  getPodIP(pod),