update DNS refresh rate

Signed-off-by: Tom <[email protected]>

Author: Flying-Tom

pkg/controller/workload/dns.go

@@ -1,3 +1,19 @@
+/*
+ * Copyright The Kmesh Authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package workload
 
 import (
@@ -12,6 +28,10 @@ import (
 	"kmesh.net/kmesh/pkg/dns"
 )
 
+const (
+	WorkloadDnsRefreshRate = 200 * time.Millisecond // 200ms, used for workload dns refresh rate
+)
+
 type dnsController struct {
 	workloadsChan chan []*workloadapi.Workload
 	cache         cache.WorkloadCache
@@ -70,7 +90,7 @@ func (r *dnsController) processDomains(workload []*workloadapi.Workload) {
 		r.pendingHostnames[workloadName] = []string{hostname}
 		r.workloadCache[hostname] = &pendingResolveDomain{
 			Workloads:   []*workloadapi.Workload{workload},
-			RefreshRate: 15 * time.Second,
+			RefreshRate: WorkloadDnsRefreshRate,
 		}
 	}
 
@@ -116,7 +136,7 @@ func (r *dnsController) refreshWorker(stop <-chan struct{}) {
 
 func (r *dnsController) updateWorkloads(pendingDomain *pendingResolveDomain, domain string, addrs []string) {
 	isWorkerUpdate := false
-	if pendingDomain == nil || addrs == nil{
+	if pendingDomain == nil || addrs == nil {
 		return
 	}
 	log.Infof("dnsController updateWorkloads: pendingDomain %v, domain %s, addrs %v", pendingDomain, domain, addrs)

pkg/controller/workload/workload_processor.go

@@ -898,23 +898,26 @@ func (p *Processor) handleServicesAndWorkloads(services []*workloadapi.Service,
 					p.DnsResolverChan <- workloads
 				}
 				go func() {
-					maxRetries := 30
+					maxRetries := 50
+					var address [][]byte
 					for range maxRetries {
 						workload := p.WorkloadCache.GetWorkloadByUid(uid)
-						address := workload.GetAddresses()
-						if address != nil {
-							log.Infof("workload: %s/%s addresses resolved: %v", workload.Namespace, workload.Name, address)
-							if err := p.handleWorkload(workload); err != nil {
-								log.Errorf("handle workload %s failed, err: %v", workload.ResourceName(), err)
-							}
+						if address = workload.GetAddresses(); address != nil {
 							break
 						} else {
-							log.Warnf("workload: %s/%s addresses is still nil, retrying...", workload.Namespace, workload.Name)
+							time.Sleep(WorkloadDnsRefreshRate)
 						}
-						time.Sleep(1 * time.Second)
+					}
+					if address != nil {
+						log.Infof("workload: %s/%s addresses resolved: %v", workload.Namespace, workload.Name, address)
+						if err := p.handleWorkload(workload); err != nil {
+							log.Errorf("handle workload %s failed, err: %v", workload.ResourceName(), err)
+						}
+					} else {
+						log.Warnf("workload: %s/%s addresses is still nil after %d retries, skipping", workload.Namespace, workload.Name, maxRetries)
 					}
 				}()
-				// wait for the service entry to be resolved
+
 			}
 		}
 		if err := p.handleWorkload(workload); err != nil {