- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 54 for makeClient (0.28 sec)
-
pkg/registry/core/service/ipallocator/controller/repair_test.go
r.updated = alloc return r.updateErr } func TestRepair(t *testing.T) { fakeClient := fake.NewSimpleClientset() ipregistry := &mockRangeRegistry{ item: &api.RangeAllocation{Range: "192.168.1.0/24"}, } _, cidr, _ := netutils.ParseCIDRSloppy(ipregistry.item.Range) r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), cidr, ipregistry, nil, nil) if err := r.runOnce(); err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 21.1K bytes - Viewed (0) -
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller_test.go
for _, obj := range test.startingClusterRoles { objs = append(objs, obj) indexer.Add(obj) } fakeClient := fakeclient.NewSimpleClientset(objs...) // The default reactor doesn't support apply, so we need our own (trivial) reactor fakeClient.PrependReactor("patch", "clusterroles", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 9K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
false, }, } for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { c := &Controller{cfg: tt.config} assert.Equal(t, c.matchesFilter(tt.pod), tt.want) }) } } func fakeClient(pods ...*corev1.Pod) kube.Client { var csPods []runtime.Object for _, pod := range pods { csPods = append(csPods, pod.DeepCopy()) } return kube.NewFakeClient(csPods...) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/volume/csi/testing/testing.go
"k8s.io/client-go/informers" fakeclient "k8s.io/client-go/kubernetes/fake" utiltesting "k8s.io/client-go/util/testing" "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/csi" volumetest "k8s.io/kubernetes/pkg/volume/testing" ) // NewTestPlugin creates a plugin mgr to load plugins and setup a fake client
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 07 00:11:50 UTC 2021 - 2.2K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair_test.go
r.updated = alloc return r.updateErr } func TestRepair(t *testing.T) { clearMetrics() fakeClient := fake.NewSimpleClientset() registry := &mockRangeRegistry{ item: &api.RangeAllocation{Range: "100-200"}, } pr, _ := net.ParsePortRange(registry.item.Range) r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), *pr, registry) if err := r.runOnce(); err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/test/utils.go
} // FakeNodeInformer creates a fakeNodeInformer using the provided fakeNodeHandler. func FakeNodeInformer(fakeNodeHandler *testutil.FakeNodeHandler) coreinformers.NodeInformer { fakeClient := &fake.Clientset{} fakeInformerFactory := informers.NewSharedInformerFactory(fakeClient, controller.NoResyncPeriodFunc()) fakeNodeInformer := fakeInformerFactory.Core().V1().Nodes() for _, node := range fakeNodeHandler.Existing {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 06 00:10:39 UTC 2022 - 2K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller_test.go
}, } for _, test := range nonReconcileTests { t.Run(test.testName, func(t *testing.T) { master := Controller{} fakeClient := fake.NewSimpleClientset(test.service) master.client = fakeClient serviceInformer := v1informers.NewServiceInformer(fakeClient, metav1.NamespaceDefault, 12*time.Hour, cache.Indexers{}) serviceStore := serviceInformer.GetIndexer() err := serviceStore.Add(test.service)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 10:41:06 UTC 2023 - 15.3K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
func CreateTestClient() *fake.Clientset { var extraPods *v1.PodList var volumeAttachments *storagev1.VolumeAttachmentList var pvs *v1.PersistentVolumeList var nodes *v1.NodeList fakeClient := &fake.Clientset{} extraPods = &v1.PodList{} fakeClient.AddReactor("list", "pods", func(action core.Action) (handled bool, ret runtime.Object, err error) { obj := &v1.PodList{} podNamePrefix := "mypod" namespace := "mynamespace"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
pkg/kubelet/secret/secret_manager_test.go
} } func noObjectTTL() (time.Duration, bool) { return time.Duration(0), false } func getSecret(fakeClient clientset.Interface) manager.GetObjectFunc { return func(namespace, name string, opts metav1.GetOptions) (runtime.Object, error) { return fakeClient.CoreV1().Secrets(namespace).Get(context.TODO(), name, opts) } } type envSecrets struct { envVarNames []string envFromNames []string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 4.5K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
} }) } } func TestMounterSetUpSimple(t *testing.T) { fakeClient := fakeclient.NewSimpleClientset() plug, tmpDir := newTestPlugin(t, fakeClient) transientError := volumetypes.NewTransientOperationFailure("") defer os.RemoveAll(tmpDir) testCases := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0)