- Sort Score
- Result 10 results
- Languages All
Results 31 - 39 of 39 for NewSharedInformerFactory (0.38 sec)
-
plugin/pkg/admission/namespace/autoprovision/admission_test.go
) // newHandlerForTest returns the admission controller configured for testing. func newHandlerForTest(c clientset.Interface) (admission.MutationInterface, informers.SharedInformerFactory, error) { f := informers.NewSharedInformerFactory(c, 5*time.Minute) handler := NewProvision() pluginInitializer := genericadmissioninitializer.New(c, nil, f, nil, nil, nil, nil) pluginInitializer.Initialize(handler) err := admission.ValidateInitialization(handler)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller_test.go
defer cancel() policy := tc.policy.DeepCopy() policy.ObjectMeta.Generation = 1 // fake storage does not do this automatically client := fake.NewSimpleClientset(policy) informerFactory := informers.NewSharedInformerFactory(client, 0) typeChecker := &validatingadmissionpolicy.TypeChecker{ SchemaResolver: resolver.NewDefinitionsSchemaResolver(openapi.GetOpenAPIDefinitions, scheme.Scheme),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller_test.go
objs := test.initialObjects if test.updatedPV != nil { objs = append(objs, test.updatedPV) } client := fake.NewSimpleClientset(objs...) // Create informers informers := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) pvInformer := informers.Core().V1().PersistentVolumes() // Populate the informers with initial objects so the controller can // Get() it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 7.5K bytes - Viewed (0) -
plugin/pkg/admission/podnodeselector/admission_test.go
} } } // newHandlerForTest returns the admission controller configured for testing. func newHandlerForTest(c kubernetes.Interface) (*Plugin, informers.SharedInformerFactory, error) { f := informers.NewSharedInformerFactory(c, 5*time.Minute) handler := NewPodNodeSelector(nil) pluginInitializer := genericadmissioninitializer.New(c, nil, f, nil, nil, nil, nil) pluginInitializer.Initialize(handler)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go
// when the WantsExternalKubeInformerFactory interface is implemented by a plugin. func TestWantsExternalKubeInformerFactory(t *testing.T) { cs := &fake.Clientset{} sf := informers.NewSharedInformerFactory(cs, time.Duration(1)*time.Second) target := initializer.New(cs, nil, sf, &TestAuthorizer{}, nil, nil, nil) wantExternalKubeInformerFactory := &WantExternalKubeInformerFactory{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller_test.go
hasError: false, }, } for _, tc := range tests { tCtx := ktesting.Init(t) test := tc fakeKubeClient := controllervolumetesting.CreateTestClient() informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc()) pvcInformer := informerFactory.Core().V1().PersistentVolumeClaims() pvc := test.pvc if tc.pv != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller_test.go
return true, nil, apierrors.NewConflict(action.GetResource().GroupResource(), "fake name", errors.New("fake conflict")) }) } setupMetrics() informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc()) podInformer := informerFactory.Core().V1().Pods() pvcInformer := informerFactory.Core().V1().PersistentVolumeClaims()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/borrowing_test.go
}, }, }, } cfgObjs = append(cfgObjs, fsObjs[flow], plcObjs[flow]) } clientset := clientsetfake.NewSimpleClientset(cfgObjs...) informerFactory := informers.NewSharedInformerFactory(clientset, time.Second) flowcontrolClient := clientset.FlowcontrolV1() clk := eventclock.Real{} controller := newTestableController(TestableConfig{ Name: "Controller",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater_test.go
} volumePluginMgr, _ := volumetesting.GetTestVolumePluginMgr(t) asw := cache.NewActualStateOfWorld(volumePluginMgr) fakeKubeClient := fake.NewSimpleClientset(&testNode1, &testNode2) informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc()) nodeInformer := informerFactory.Core().V1().Nodes() nsu := NewNodeStatusUpdater(fakeKubeClient, nodeInformer.Lister(), asw)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 8.4K bytes - Viewed (0)