api后端接口，时快时慢

[silenceper]

装了一下naftis，首先显示是总共36个服务，总pod 39

在刷新一下页面 的接口
/api/services
/api/diagnose
/api/tasktmpls
发现有时候会有10s的请求是从，而有时候就是ms内

[silenceper]

跟踪了下，应该是这段代码导致的

naftis/src/api/service/kube.go

Lines 328 to 364 in 9d4556f

	func (k *kubeInfo) sync() {
	for {
	log.Debug("[Kube] sync start", "svcs", len(k.services), "namespace", k.namespace, "time", time.Now())
	svcs, err := client.CoreV1().Services(k.namespace).List(metav1.ListOptions{
	LabelSelector: "provider!=kubernetes",
	})
	if err != nil {
	// panic(err.Error())
	log.Error("[k8s] get services err", "err", err)
	}
	ns, err := client.CoreV1().Namespaces().List(metav1.ListOptions{
	LabelSelector: "provider!=kubernetes",
	})
	if err != nil {
	// panic(err.Error())
	log.Error("[k8s] get namespaces err", "err", err)
	}
	k.mtx.Lock()
	k.services = make([]service, 0, len(svcs.Items))
	k.wg.Add(len(svcs.Items))
	for _, i := range svcs.Items {
	go func(i v1.Service) {
	s := service{}
	s.Service = i
	s.Pods = k.Pods(i.Spec.Selector)
	k.services = append(k.services, s)
	k.wg.Done()
	}(i)
	}
	k.wg.Wait()
	k.namespaces = ns.Items
	k.mtx.Unlock()
	log.Debug("[Kube] sync end", "svcs", len(k.services), "namespace", k.namespace, "time", time.Now())
	time.Sleep(k.syncInterval)
	}
	}

这里加了锁，在读的时候必须等sync结束才能响应。