- Sort Score
- Result 10 results
- Languages All
Results 31 - 36 of 36 for makeClient (0.15 sec)
-
pkg/controller/replicaset/replica_set_test.go
rs := newReplicaSet(1, map[string]string{"foo": "bar"}) fakeClient := &fake.Clientset{} fakeClient.AddReactor("get", "replicasets", func(action core.Action) (bool, runtime.Object, error) { return true, rs, nil }) fakeClient.AddReactor("*", "*", func(action core.Action) (bool, runtime.Object, error) { return true, &apps.ReplicaSet{}, fmt.Errorf("fake error") }) fakeRSClient := fakeClient.AppsV1().ReplicaSets("default") numReplicas := int32(10)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/controller/controller_utils_test.go
"Body: %s", fakeHandler.RequestBody) }) } } func TestDeletePodsAllowsMissing(t *testing.T) { fakeClient := fake.NewSimpleClientset() podControl := RealPodControl{ KubeClient: fakeClient, Recorder: &record.FakeRecorder{}, } controllerSpec := newReplicationController(1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal_test.go
} if tc.resource == nil { tc.resource = &fakeResource{ name: "test-rc", apiVersion: "v1", kind: "ReplicationController", } } tc.Unlock() fakeClient := &fake.Clientset{} fakeClient.AddReactor("list", "horizontalpodautoscalers", func(action core.Action) (handled bool, ret runtime.Object, err error) { tc.Lock() defer tc.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 199.3K bytes - Viewed (0) -
pkg/kube/client.go
return } if meta.GetName() == "" && meta.GetGenerateName() != "" { meta.SetName(names.SimpleNameGenerator.GenerateName(meta.GetGenerateName())) } return } for _, fc := range []fakeClient{ c.kube.(*fake.Clientset), c.istio.(*istiofake.Clientset), c.gatewayapi.(*gatewayapifake.Clientset), c.dynamic.(*dynamicfake.FakeDynamicClient), c.metadata.(*metadatafake.FakeMetadataClient), } {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
ds := newDaemonSet("foo") fakeClient := &fake.Clientset{} getCalled := 0 fakeClient.AddReactor("get", "daemonsets", func(action core.Action) (bool, runtime.Object, error) { getCalled += 1 if getCalled <= tt.getErrorNum { return true, nil, getError } return true, ds, nil }) updateCalled := 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
t.Run(name, func(t *testing.T) { t.Cleanup(setDurationDuringTest(&DefaultJobApiBackOff, fastJobApiBackoff)) fakeClient := clocktesting.NewFakeClock(time.Now()) manager, sharedInformerFactory := newControllerFromClientWithClock(ctx, t, clientset, controller.NoResyncPeriodFunc, fakeClient) fakePodControl := controller.FakePodControl{} manager.podControl = &fakePodControl manager.podStoreSynced = alwaysReady
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)