Fix checking informer syncing

kubernetes-sigs · May 12, 2020 · 474176d · 474176d
1 parent a6b5fa7
commit 474176d
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 2 deletions.
diff --git a/source/service.go b/source/service.go
@@ -122,7 +122,10 @@ func NewServiceSource(kubeClient kubernetes.Interface, namespace, annotationFilt
 
 	// wait for the local cache to be populated.
 	err = poll(time.Second, 60*time.Second, func() (bool, error) {
-		return serviceInformer.Informer().HasSynced(), nil
+		return serviceInformer.Informer().HasSynced() &&
+			endpointsInformer.Informer().HasSynced() &&
+			podInformer.Informer().HasSynced() &&
+			nodeInformer.Informer().HasSynced(), nil
 	})
 	if err != nil {
 		return nil, fmt.Errorf("failed to sync cache: %v", err)

diff --git a/source/source.go b/source/source.go
@@ -229,8 +229,20 @@ func matchLabelSelector(selector labels.Selector, srcAnnotations map[string]stri
 
 func poll(interval time.Duration, timeout time.Duration, condition wait.ConditionFunc) error {
 	if config.FAST_POLL {
+		time.Sleep(5 * time.Millisecond)
+
+		ok, err := condition()
+
+		if err != nil {
+			return err
+		}
+
+		if ok {
+			return nil
+		}
+
 		interval = 50 * time.Millisecond
-		timeout = 5 * time.Second
+		timeout = 10 * time.Second
 	}
 
 	return wait.Poll(interval, timeout, condition)