- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 54 for makeClient (0.17 sec)
-
pkg/controller/resourceclaim/controller_test.go
scheduling[i].Name < scheduling[j].Name }) return scheduling } func createTestClient(objects ...runtime.Object) *fake.Clientset { fakeClient := fake.NewSimpleClientset(objects...) fakeClient.PrependReactor("create", "resourceclaims", createResourceClaimReactor()) return fakeClient } // createResourceClaimReactor implements the logic required for the GenerateName field to work when using
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/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
fakeClient := &fake.Clientset{} fakeClient.AddReactor("get", "persistentvolumeclaims", func(action core.Action) (bool, runtime.Object, error) { return false, nil, nil }) fakeClient.AddReactor("get", "persistentvolumes", func(action core.Action) (bool, runtime.Object, error) { return false, nil, nil }) dswp.kubeClient = fakeClient }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
objs := append([]runtime.Object{&v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: ""}}}, nodes...) fakeClient := fake.NewSimpleClientset(objs...) informerFactory := informers.NewSharedInformerFactory(fakeClient, 0) eventBroadcaster := events.NewBroadcaster(&events.EventSinkImpl{Interface: fakeClient.EventsV1()}) eventRecorder := eventBroadcaster.NewRecorder(scheme.Scheme, fakePermit)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/volume/csi/csi_test.go
storage "k8s.io/api/storage/v1" meta "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/informers" fakeclient "k8s.io/client-go/kubernetes/fake" utiltesting "k8s.io/client-go/util/testing" "k8s.io/kubernetes/pkg/volume" volumetest "k8s.io/kubernetes/pkg/volume/testing" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
pkg/controller/podautoscaler/replica_calculator_test.go
const ( testNamespace = "test-namespace" podNamePrefix = "test-pod" numContainersPerPod = 2 ) func (tc *replicaCalcTestCase) prepareTestClientSet() *fake.Clientset { fakeClient := &fake.Clientset{} fakeClient.AddReactor("list", "pods", func(action core.Action) (handled bool, ret runtime.Object, err error) { obj := &v1.PodList{} podsCount := int(tc.currentReplicas)
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/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) -
staging/src/k8s.io/cli-runtime/pkg/resource/builder_test.go
buf := &bytes.Buffer{} codec := corev1Codec enc := restclientwatch.NewEncoder(streaming.NewEncoder(buf, codec), codec) for _, e := range events { enc.Encode(&e) } return buf.String() } func fakeClient() FakeClientFunc { return func(version schema.GroupVersion) (RESTClient, error) { return &fake.RESTClient{}, nil } } func fakeClientWith(testName string, t *testing.T, data map[string]string) FakeClientFunc {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 11:58:41 UTC 2023 - 56.1K 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)