- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 407 for Informer (0.63 sec)
-
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/history/controller_history_test.go
client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) stop := make(chan struct{}) defer close(stop) informerFactory.Start(stop) informer := informerFactory.Apps().V1().ControllerRevisions() informerFactory.WaitForCacheSync(stop) for i := range test.revisions { informer.Informer().GetIndexer().Add(test.revisions[i]) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 49.1K 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/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) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
hasProcessed synctrack.AsyncTracker[string] } type ControllerOptions struct { Name string Workers uint } func (c *controller[T]) Informer() Informer[T] { return c.informer } func NewController[T runtime.Object]( informer Informer[T], reconciler func(namepace, name string, newObj T) error, options ControllerOptions, ) Controller[T] { if options.Workers == 0 { options.Workers = 2 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K 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/internal/generic/interface.go
// is concerned with. // // Returns an error always non-nil explaining why the worker stopped Run(ctx context.Context) error // Retrieves the informer used to back this controller Informer() Informer[T] // Returns true if the informer cache has synced, and all the objects from // the initial list have been reconciled at least once. HasSynced() bool } type NamespacedLister[T any] interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager.go
// We need to call Informer() before calling start on the shared informer // factory, or the informer won't be registered to be started. m := &InformerManager{ ctbInformer: bundles.Informer(), ctbLister: bundles.Lister(), normalizationCache: lrucache.NewLRUExpireCache(cacheSize), cacheTTL: cacheTTL, } // Have the informer bust cache entries when it sees updates that could
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 8.3K bytes - Viewed (0)