- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 218 for Informer (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
nil, ) go informer.Informer().Run(instanceContext.Done()) } klog.Infof("informer started for %v", *paramSource) ret := ¶mInfo{ mapping: *mapping, cancelFunc: instanceCancel, informer: informer, } s.paramsCRDControllers[*paramSource] = ret return ret.informer, mapping.Scope, nil } // For testing
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
}() // Wait for controller and informer to start up require.True(t, cache.WaitForCacheSync(testContext.Done(), myController.HasSynced)) // Stop the controller and informer testCancel() // Wait for controller and informer to stop wg.Wait() // Ensure the event handler was cleaned up require.Empty(t, informer.registrations) verifyNoMoreEvents() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/plugin_test.go
wh.SetExternalKubeClientSet(client) wh.SetExternalKubeInformerFactory(informer) informer.Start(stopCh) informer.WaitForCacheSync(stopCh) if err = wh.ValidateInitialization(); err != nil { t.Errorf("%s: failed to validate initialization: %v", tt.Name, err) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11K bytes - Viewed (0) -
pkg/scheduler/util/assumecache/assume_cache.go
// - The pointer to the informer object. // - The pointer to the latest object, which could be the same as // the informer object, or an in-memory object. // // An informer update always overrides the latest object pointer. // // Assume() only updates the latest object pointer. // Restore() sets the latest object pointer back to the informer object. // Get/List() always returns the latest object pointer.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 10.6K bytes - Viewed (0) -
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager_test.go
informerFactory := informers.NewSharedInformerFactoryWithOptions(kc, 0) ctbInformer := informerFactory.Certificates().V1alpha1().ClusterTrustBundles() ctbManager, _ := NewInformerManager(ctbInformer, 256, 5*time.Minute) informerFactory.Start(ctx.Done()) if !cache.WaitForCacheSync(ctx.Done(), ctbInformer.Informer().HasSynced) { t.Fatalf("Timed out waiting for informer to sync") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 15.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/plugin_test.go
wh.SetExternalKubeClientSet(client) wh.SetExternalKubeInformerFactory(informer) informer.Start(stopCh) informer.WaitForCacheSync(stopCh) if err = wh.ValidateInitialization(); err != nil { t.Errorf("%s: failed to validate initialization: %v", tt.Name, err) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
informerFactory.Core().V1().Pods().Informer().HasSynced, informerFactory.Core().V1().Nodes().Informer().HasSynced, informerFactory.Storage().V1().CSINodes().Informer().HasSynced) { t.Fatalf("Error waiting for the informer caches to sync") } // Make sure the nodes and pods are in the informer cache i = 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
if handlerRegistration, err = informerFactory.Storage().V1().CSINodes().Informer().AddEventHandler( buildEvtResHandler(at, framework.CSINode, "CSINode"), ); err != nil { return err } handlers = append(handlers, handlerRegistration) case framework.CSIDriver: if handlerRegistration, err = informerFactory.Storage().V1().CSIDrivers().Informer().AddEventHandler( buildEvtResHandler(at, framework.CSIDriver, "CSIDriver"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
pkg/kube/kclient/client.go
// with a full client readyNow := delay.KnownOrCallback(func(stop <-chan struct{}) { // The inf() call is responsible for starting the informer inf := getInf() fc := &informerClient[T]{ informer: inf.Informer, startInformer: inf.Start, } applyDynamicFilter(filter, gvr, fc) inf.Start(stop) log.Infof("%v is now ready, building client", gvr.GroupResource())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
return false, fmt.Errorf("timed out waiting for cache sync of param informer") } var lister cache.GenericNamespaceLister = informer.Lister() if scope == meta.RESTScopeNamespace { lister = informer.Lister().ByNamespace(objectMeta.GetNamespace()) } fetched, err := lister.Get(objectMeta.GetName()) if err != nil { if errors.IsNotFound(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0)