- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 111 for NewSharedInformerFactory (0.77 sec)
-
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller_test.go
) func newController(t *testing.T, objects []*networkingapiv1alpha1.ServiceCIDR) (*fake.Clientset, *Controller) { client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0) serviceCIDRInformer := informerFactory.Networking().V1alpha1().ServiceCIDRs() store := serviceCIDRInformer.Informer().GetStore() for _, obj := range objects { err := store.Add(obj)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 14 23:31:58 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller_test.go
ObjectMeta: metav1.ObjectMeta{ Name: ns, Namespace: "", }, }, ) } clientset := fake.NewSimpleClientset(objs...) informerFactory := informers.NewSharedInformerFactory(clientset, 0) namespaceInformer := informerFactory.Core().V1().Namespaces() for _, obj := range objs { namespaceInformer.Informer().GetIndexer().Add(obj) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config_test.go
return fmt.Errorf("delegate failed healthcheck") })) sharedInformers := informers.NewSharedInformerFactory(clientset, delegateConfig.LoopbackClientConfig.Timeout) delegateServer, err := delegateConfig.Complete(sharedInformers).New("test", NewEmptyDelegate()) if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 13.1K bytes - Viewed (0) -
plugin/pkg/admission/network/defaultingressclass/admission_test.go
expectedError: nil, }, } for _, testCase := range testCases { t.Run(testCase.name, func(t *testing.T) { ctrl := newPlugin() informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc()) ctrl.SetExternalKubeInformerFactory(informerFactory) for _, c := range testCase.classes { informerFactory.Networking().V1().IngressClasses().Informer().GetStore().Add(c)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 04 13:12:32 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/controller/serviceaccount/serviceaccounts_controller_test.go
ExpectCreatedServiceAccounts: []string{}, }, } for k, tc := range testcases { client := fake.NewSimpleClientset(defaultServiceAccount, managedServiceAccount) informers := informers.NewSharedInformerFactory(fake.NewSimpleClientset(), controller.NoResyncPeriodFunc()) options := DefaultServiceAccountsControllerOptions() options.ServiceAccounts = []v1.ServiceAccount{ {ObjectMeta: metav1.ObjectMeta{Name: defaultName}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 03 00:46:06 UTC 2021 - 7.6K bytes - Viewed (0) -
pkg/controller/deployment/recreate_test.go
t.Errorf("broken test - original and expected RS have the same size") } } kc := fake.NewSimpleClientset(expected...) informers := informers.NewSharedInformerFactory(kc, controller.NoResyncPeriodFunc()) _, ctx := ktesting.NewTestContext(t) c, err := NewDeploymentController(ctx, informers.Apps().V1().Deployments(), informers.Apps().V1().ReplicaSets(), informers.Core().V1().Pods(), kc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/metrics/metrics_test.go
) func TestVolumesInUseMetricCollection(t *testing.T) { fakeVolumePluginMgr, _ := volumetesting.GetTestVolumePluginMgr(t) fakeClient := &fake.Clientset{} fakeInformerFactory := informers.NewSharedInformerFactory(fakeClient, controller.NoResyncPeriodFunc()) fakePodInformer := fakeInformerFactory.Core().V1().Pods() pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "metric-test-pod",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 6.1K bytes - Viewed (0) -
plugin/pkg/admission/storage/persistentvolume/resize/admission_test.go
checkError: func(err error) bool { return strings.Contains(err.Error(), "Only bound persistent volume claims can be expanded") }, }, } ctrl := newPlugin() informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc()) ctrl.SetExternalKubeInformerFactory(informerFactory) err := ctrl.ValidateInitialization() if err != nil { t.Fatalf("neither pv lister nor storageclass lister can be nil")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 7.7K bytes - Viewed (0) -
plugin/pkg/admission/storage/storageclass/setdefault/admission_test.go
klog.V(4).Infof("starting test %q", test.name) // clone the claim, it's going to be modified claim := test.claim.DeepCopy() ctrl := newPlugin() informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc()) ctrl.SetExternalKubeInformerFactory(informerFactory) for _, c := range test.classes { informerFactory.Storage().V1().StorageClasses().Informer().GetStore().Add(c) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 19 04:00:48 UTC 2022 - 7.6K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher_test.go
UpdatedNamespace: terminatingNS, }, } for k, tc := range testcases { t.Run(k, func(t *testing.T) { client := fake.NewSimpleClientset(caConfigMap, existNS) informers := informers.NewSharedInformerFactory(fake.NewSimpleClientset(), controller.NoResyncPeriodFunc()) cmInformer := informers.Core().V1().ConfigMaps() nsInformer := informers.Core().V1().Namespaces()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:16 UTC 2023 - 7.9K bytes - Viewed (0)