- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for HasSynced (0.14 sec)
-
pkg/revisions/tag_watcher.go
return } // Notify handlers of initial state p.notifyHandlers() p.queue.Run(stopCh) } // AddHandler registers a new handler for updates to tag changes. func (p *tagWatcher) AddHandler(handler TagHandler) { p.handlers = append(p.handlers, handler) } func (p *tagWatcher) HasSynced() bool { return p.queue.HasSynced() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
// watches too often. MinWatchTimeout: 30 * time.Minute, }, ) item := &objectCacheItem{ refMap: make(map[types.UID]int), store: store, reflector: reflector, hasSynced: func() (bool, error) { return store.hasSynced(), nil }, stopCh: make(chan struct{}), } // Don't start reflector if Kubelet is already shutting down. if !c.stopped { go item.startReflector() } return item }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/kube/krt/informer.go
i.inf.AddEventHandler(informerEventHandler[I](func(o Event[I], initialSync bool) { f([]Event[I]{o}, initialSync) })) } return pollSyncer{ name: fmt.Sprintf("%v handler", i.name()), f: i.inf.HasSynced, } } func informerEventHandler[I controllers.ComparableObject](handler func(o Event[I], initialSync bool)) cache.ResourceEventHandler { return controllers.EventHandler[I]{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
} func (cl *Client) informerSynced() bool { for gk, ctl := range cl.allKinds() { if !ctl.HasSynced() { cl.logger.Infof("controller %q is syncing...", gk) return false } } return true } func (cl *Client) HasSynced() bool { return cl.queue.HasSynced() } // Schemas for the store func (cl *Client) Schemas() collection.Schemas { return cl.schemas }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
tracker := assert.NewTracker[string](t) wasm.AddEventHandler(clienttest.TrackerHandler(tracker)) go constantlyAccessForRaceDetection(stop, wasm) c.RunAndWait(stop) kube.WaitForCacheSync("test", test.NewStop(t), wasm.HasSynced) wt.Create(&istioclient.WasmPlugin{ ObjectMeta: metav1.ObjectMeta{Name: "name", Namespace: "default"}, }) assert.EventuallyEqual(t, func() int { return len(wasm.List("", klabels.Everything())) }, 1)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
recorder), NewRealStatefulSetStatusUpdater(kubeClient, setInformer.Lister()), history.NewHistory(kubeClient, revInformer.Lister()), ), pvcListerSynced: pvcInformer.Informer().HasSynced, revListerSynced: revInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "statefulset"}, ),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
c.servicesSynced = serviceInformer.Informer().HasSynced podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addPod, UpdateFunc: c.updatePod, DeleteFunc: c.deletePod, }) c.podLister = podInformer.Lister() c.podsSynced = podInformer.Informer().HasSynced c.nodeLister = nodeInformer.Lister() c.nodesSynced = nodeInformer.Informer().HasSynced logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/nodeipam/node_ipam_controller.go
if err != nil { return nil, err } } ic.nodeLister = nodeInformer.Lister() ic.nodeInformerSynced = nodeInformer.Informer().HasSynced return ic, nil } // Run starts an asynchronous loop that monitors the status of cluster nodes. func (nc *Controller) Run(ctx context.Context) { defer utilruntime.HandleCrash()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
} if util.PodRedirectionEnabled(ns, pod) { return pod, nil } return nil, nil } func (s *InformerHandlers) Start() { kube.WaitForCacheSync("informer", s.ctx.Done(), s.pods.HasSynced, s.namespaces.HasSynced) go s.queue.Run(s.ctx.Done()) } // Gets a point-in-time snapshot of all pods that are CURRENTLY ambient enabled // (as per control plane annotation)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
pilot/test/xds/fake.go
s.Start(stop) cg.ServiceEntryRegistry.XdsUpdater = s // Now that handlers are added, get everything started cg.Run() kubelib.WaitForCacheSync("fake", stop, cg.Registry.HasSynced, cg.Store().HasSynced) cg.ServiceEntryRegistry.ResyncEDS() // Send an update. This ensures that even if there are no configs provided, the push context is // initialized. s.ConfigUpdate(&model.PushRequest{Full: true})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0)