mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-12 13:31:52 +00:00
Check return value when calling ensureDnsRecords
This commit is contained in:
parent
31da82df52
commit
d4fa23feb8
@ -728,11 +728,15 @@ func (s *ServiceController) lockedUpdateDNSRecords(service *cachedService, clust
|
||||
for key := range s.clusterCache.clientMap {
|
||||
for _, clusterName := range clusterNames {
|
||||
if key == clusterName {
|
||||
s.ensureDnsRecords(clusterName, service)
|
||||
err := s.ensureDnsRecords(clusterName, service)
|
||||
if err != nil {
|
||||
glog.Errorf("Failed to ensure DNS records for service %v in cluster %s due to %v", service, clusterName, err)
|
||||
} else {
|
||||
ensuredCount += 1
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
if ensuredCount < len(clusterNames) {
|
||||
return fmt.Errorf("Failed to update DNS records for %d of %d clusters for service %v due to missing clients for those clusters",
|
||||
len(clusterNames)-ensuredCount, len(clusterNames), service)
|
||||
|
Loading…
Reference in New Issue
Block a user