- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for nodeHasSynced (0.11 sec)
-
pkg/kubelet/config/apiserver.go
const WaitForAPIServerSyncPeriod = 1 * time.Second // NewSourceApiserver creates a config source that watches and pulls from the apiserver. func NewSourceApiserver(c clientset.Interface, nodeName types.NodeName, nodeHasSynced func() bool, updates chan<- interface{}) { lw := cache.NewListWatchFromClient(c.CoreV1().RESTClient(), "pods", metav1.NamespaceAll, fields.OneTermEqualSelector("spec.nodeName", string(nodeName)))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 21 19:46:27 UTC 2021 - 2.4K bytes - Viewed (0)