- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for CreateTestClient (0.19 sec)
-
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
volumePluginMgr, fakePlugin := volumetesting.GetTestVolumePluginMgr(t) dsw := cache.NewDesiredStateOfWorld(volumePluginMgr) asw := cache.NewActualStateOfWorld(volumePluginMgr) fakeKubeClient := controllervolumetesting.CreateTestClient() fakeRecorder := &record.FakeRecorder{} fakeHandler := volumetesting.NewBlockVolumePathHandler() ad := operationexecutor.NewOperationExecutor(operationexecutor.NewOperationGenerator( fakeKubeClient,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller_test.go
var objects []runtime.Object for _, pod := range tc.pods { objects = append(objects, pod) } for _, pvc := range tc.pvcs { objects = append(objects, pvc) } fakeKubeClient := createTestClient(objects...) if tc.expectedMetrics.numFailures > 0 { fakeKubeClient.PrependReactor("create", "persistentvolumeclaims", func(action k8stesting.Action) (handled bool, ret runtime.Object, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
seLinuxTranslator := util.NewFakeSELinuxLabelTranslator() dsw := cache.NewDesiredStateOfWorld(volumePluginMgr, seLinuxTranslator) asw := cache.NewActualStateOfWorld(nodeName, volumePluginMgr) kubeClient := createTestClient() fakeRecorder := &record.FakeRecorder{} fakeHandler := volumetesting.NewBlockVolumePathHandler() oex := operationexecutor.NewOperationExecutor(operationexecutor.NewOperationGenerator( kubeClient, volumePluginMgr,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
} return adcObj.(*attachDetachController) } func Test_NewAttachDetachController_Positive(t *testing.T) { // Arrange fakeKubeClient := controllervolumetesting.CreateTestClient() informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc()) tCtx := ktesting.Init(t) // Act createADC(t, tCtx, fakeKubeClient, informerFactory, nil) }
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/volume/expand/expand_controller_test.go
expansionCalled: false, 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/resourceclaim/controller_test.go
} for _, claim := range tc.claims { objects = append(objects, claim) } for _, template := range tc.templates { objects = append(objects, template) } fakeKubeClient := createTestClient(objects...) if tc.expectedMetrics.numFailures > 0 { fakeKubeClient.PrependReactor("create", "resourceclaims", func(action k8stesting.Action) (handled bool, ret runtime.Object, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 08:56:16 UTC 2024 - 28.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
}, }, PersistentVolume: &v1.PersistentVolume{ Spec: v1.PersistentVolumeSpec{ AccessModes: []v1.PersistentVolumeAccessMode{ v1.ReadWriteOnce, }, }, }, } } func CreateTestClient() *fake.Clientset { var extraPods *v1.PodList var volumeAttachments *storagev1.VolumeAttachmentList var pvs *v1.PersistentVolumeList var nodes *v1.NodeList fakeClient := &fake.Clientset{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0)