- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 47 for makeClient (0.16 sec)
-
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/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/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) -
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator_test.go
) func TestFindAndAddActivePods_FindAndRemoveDeletedPods(t *testing.T) { fakeVolumePluginMgr, _ := volumetesting.GetTestVolumePluginMgr(t) fakeClient := &fake.Clientset{} fakeInformerFactory := informers.NewSharedInformerFactory(fakeClient, controller.NoResyncPeriodFunc()) fakePodInformer := fakeInformerFactory.Core().V1().Pods() fakesDSW := cache.NewDesiredStateOfWorld(fakeVolumePluginMgr)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 7.3K bytes - Viewed (0) -
pkg/kubelet/certificate/bootstrap/bootstrap_test.go
const ( noError failureType = iota //nolint:deadcode,varcheck createError certificateSigningRequestDenied ) type fakeClient struct { certificatesclient.CertificateSigningRequestInterface failureType failureType } func newClientset(opts fakeClient) *fake.Clientset { f := fake.NewSimpleClientset() switch opts.failureType { case createError:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 09 14:24:11 UTC 2023 - 13K bytes - Viewed (0) -
istioctl/pkg/tag/generate_test.go
defaultWh := defaultRevisionCanonicalWebhook.DeepCopy() fakeClient := kube.NewFakeClient(defaultWh) opts := &GenerateOptions{ Generate: generate, Tag: "default", Revision: "default", } _, err := Generate(context.TODO(), fakeClient, opts, "istio-system") assert.NoError(t, err) wh, err := fakeClient.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations().
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 16 17:43:49 UTC 2024 - 12.1K bytes - Viewed (0)