- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for Informer (0.17 sec)
-
pkg/controller/replicaset/replica_set_test.go
defer close(stopCh) manager, fakePodControl, informers := setupManagerWithGCEnabled(t, stopCh, rs) informers.Apps().V1().ReplicaSets().Informer().GetIndexer().Add(rs) // add to podLister two matching pods. Expect two patches to take control // them. informers.Core().V1().Pods().Informer().GetIndexer().Add(newPod("pod1", rs, v1.PodRunning, nil, false))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
dc, informerFactory.Core().V1().Pods().Informer().GetStore(), informerFactory.Policy().V1().PodDisruptionBudgets().Informer().GetStore(), informerFactory.Core().V1().ReplicationControllers().Informer().GetStore(), informerFactory.Apps().V1().ReplicaSets().Informer().GetStore(), informerFactory.Apps().V1().Deployments().Informer().GetStore(), informerFactory.Apps().V1().StatefulSets().Informer().GetStore(), coreClient,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
plugin/pkg/admission/resourcequota/admission_test.go
defer close(stopCh) kubeClient := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(kubeClient, 0) handler, err := createHandler(kubeClient, informerFactory, stopCh) if err != nil { t.Errorf("Error occurred while creating admission plugin: %v", err) } informerFactory.Core().V1().ResourceQuotas().Informer().GetIndexer().Add(resourceQuota)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 84.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
// while the scheduler has allocated it and the corresponding object // update from the apiserver has not been processed by the claim // informer callbacks. Claims get added here in PreBind and removed by // the informer callback (based on the "newer than" comparison in the // assume cache). // // It uses cache.MetaNamespaceKeyFunc to generate object names, which
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
return nil }), }) nc.leaseLister = leaseInformer.Lister() nc.leaseInformerSynced = leaseInformer.Informer().HasSynced nc.nodeInformerSynced = nodeInformer.Informer().HasSynced nc.daemonSetStore = daemonSetInformer.Lister() nc.daemonSetInformerSynced = daemonSetInformer.Informer().HasSynced return nc, nil } // Run starts an asynchronous loop that monitors the status of cluster nodes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
dsc.podStoreSynced = podInformer.Informer().HasSynced nodeInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { dsc.addNode(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { dsc.updateNode(logger, oldObj, newObj) }, }, ) dsc.nodeStoreSynced = nodeInformer.Informer().HasSynced dsc.nodeLister = nodeInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
classInformer, capacityCheck, 10*time.Second) // Wait for informers cache sync informerFactory.Start(ctx.Done()) for v, synced := range informerFactory.WaitForCacheSync(ctx.Done()) { if !synced { logger.Error(nil, "Error syncing informer", "informer", v) os.Exit(1) } } // Add storageclasses waitMode := storagev1.VolumeBindingWaitForFirstConsumer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
return client, &endpointSliceController{ esController, informerFactory.Discovery().V1().EndpointSlices().Informer().GetStore(), informerFactory.Core().V1().Nodes().Informer().GetStore(), informerFactory.Core().V1().Pods().Informer().GetStore(), informerFactory.Core().V1().Services().Informer().GetStore(), } } func newPod(n int, namespace string, ready bool, nPorts int, terminating bool) *v1.Pod {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
ObjectMeta: metav1.ObjectMeta{Name: string(nodeName1)}, Spec: v1.NodeSpec{ Taints: []v1.Taint{{Key: v1.TaintNodeOutOfService, Effect: v1.TaintEffectNoExecute}}, }, } informerFactory.Core().V1().Nodes().Informer().GetStore().Add(node1) dsw.AddNode(nodeName1) volumeExists := dsw.VolumeExists(volumeName1, nodeName1) if volumeExists { t.Fatalf( "Volume %q/node %q should not exist, but it does.", volumeName1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
monitor monitor.Monitor // hpaLister is able to list/get HPAs from the shared cache from the informer passed in to // NewHorizontalController. hpaLister autoscalinglisters.HorizontalPodAutoscalerLister hpaListerSynced cache.InformerSynced // podLister is able to list/get Pods from the shared cache from the informer passed in to // NewHorizontalController. podLister corelisters.PodLister
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0)