in pkg/probe/gke.go [115:138]
func (p *kubeDnsProbe) Run(context.Context, *kubernetes.Clientset) Result {
ips, err := net.LookupIP(p.host)
if err != nil {
klog.Warningf("Dns Lookup response failed from KubeDNS: %s\n", err.Error())
return Result{
Available: "Unhealthy",
Err: err,
}
}
if len(ips) == 0 {
err = fmt.Errorf("no IPs returned in dns lookup response from KubeDNS")
return Result{
Available: "Unhealthy",
Err: err,
}
}
klog.V(1).Infof("Dns lookup responses from KubeDNS returns %s\n", ips[0])
err = fmt.Errorf("KubeDNS is operational health")
return Result{
Available: "Healthy",
Err: err,
}
}