- Sort Score
- Result 10 results
- Languages All
Results 11 - 15 of 15 for NewSharedInformerFactory (0.37 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
clientset := newClientset(t, apfConfiguration...) // this test does not rely on resync, so resync period is set to zero factory := informers.NewSharedInformerFactory(clientset, 0) controller := utilflowcontrol.New(factory, clientset.FlowcontrolV1(), serverConcurrency) factory.Start(stopCh) // wait for the informer cache to sync.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/controller/podautoscaler/replica_calculator_test.go
metricsClient := metricsclient.NewRESTMetricsClient(testMetricsClient.MetricsV1beta1(), testCMClient, testEMClient) informerFactory := informers.NewSharedInformerFactory(testClient, controller.NoResyncPeriodFunc()) informer := informerFactory.Core().V1().Pods()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 19 03:31:34 UTC 2023 - 68.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
tc.client.PrependReactor("list", "resourceclassparameters", createListReactor(tc.client.Tracker(), "ResourceClassParameters")) tc.informerFactory = informers.NewSharedInformerFactory(tc.client, 0) opts := []runtime.Option{ runtime.WithClientSet(tc.client), runtime.WithInformerFactory(tc.informerFactory), } fh, err := runtime.NewFramework(tCtx, nil, nil, opts...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
} func newController(t *testing.T, nodeNames []string, batchPeriod time.Duration) (*fake.Clientset, *endpointSliceController) { client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) nodeInformer := informerFactory.Core().V1().Nodes() indexer := nodeInformer.Informer().GetIndexer() for _, nodeName := range nodeNames {
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/scheduler/framework/plugins/volumebinding/binder_test.go
ns := action.GetNamespace() watch, err := reactor.Watch(gvr, ns) if err != nil { return false, nil, err } return true, watch, nil }) informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) podInformer := informerFactory.Core().V1().Pods() nodeInformer := informerFactory.Core().V1().Nodes() csiNodeInformer := informerFactory.Storage().V1().CSINodes()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0)