- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for fakediscovery (0.24 sec)
-
cmd/kube-controller-manager/app/core_test.go
ret, err := m.DiscoveryClient(name) if err != nil { panic(err) } return ret } // FakeDiscoveryWithError inherits DiscoveryInterface(via FakeDiscovery) with some methods accepting testing data. type FakeDiscoveryWithError struct { fakediscovery.FakeDiscovery PossibleResources []*metav1.APIResourceList Err error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:01 UTC 2023 - 5.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake/clientset_generated.go
o := testing.NewObjectTracker(scheme, codecs.UniversalDecoder()) for _, obj := range objects { if err := o.Add(obj); err != nil { panic(err) } } cs := &Clientset{tracker: o} cs.discovery = &fakediscovery.FakeDiscovery{Fake: &cs.Fake} cs.AddReactor("*", "*", testing.ObjectReaction(o)) cs.AddWatchReactor("*", func(action testing.Action) (handled bool, ret watch.Interface, err error) { gvr := action.GetResource()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 21:36:26 UTC 2023 - 3.2K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/common.go
fakeclient := apiclient.NewDryRunClientWithOpts(dryRunOpts) // As we know the return of Discovery() of the fake clientset is of type *fakediscovery.FakeDiscovery // we can convert it to that struct. fakeclientDiscovery, ok := fakeclient.Discovery().(*fakediscovery.FakeDiscovery) if !ok { return nil, errors.New("couldn't set fake discovery's server version") } // Lastly, set the right server version to be used
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 10.1K bytes - Viewed (0) -
pkg/kube/version_test.go
gitVersion: "v1.28.9-eks-036c24b", want: 128, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { c := NewFakeClient() c.Kube().Discovery().(*fakediscovery.FakeDiscovery).FakedServerVersion = &kubeVersion.Info{Major: tt.major, Minor: tt.minor, GitVersion: tt.gitVersion} if got := GetVersionAsInt(c); got != tt.want { t.Errorf("TestGetVersionAsInt() = %v, want %v", got, tt.want)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 23:16:29 UTC 2024 - 3.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/dryrunclient_test.go
controlPlaneName: "controlPlane", serviceSubnet: "serviceSubnet", } c := NewDryRunClient(dryRunGetter, io.Discard) fakeclientDiscovery, ok := c.Discovery().(*fakediscovery.FakeDiscovery) if !ok { t.Fatal("could not obtain FakeDiscovery from dry run client") } const gitVersion = "foo" fakeclientDiscovery.FakedServerVersion = &pkgversion.Info{GitVersion: gitVersion} ver, err := c.Discovery().ServerVersion()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 21 09:49:59 UTC 2022 - 4.5K bytes - Viewed (0) -
operator/pkg/util/k8s_test.go
major: "1", minor: "24", expErr: false, operatorYaml: o3, }, } for i, tt := range tests { k8sClient := kube.NewFakeClient() k8sClient.Kube().Discovery().(*fakediscovery.FakeDiscovery).FakedServerVersion = &version.Info{ Major: tt.major, Minor: tt.minor, } op := &pkgAPI.IstioOperator{} err = yaml.Unmarshal([]byte(tt.operatorYaml), op) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 3.5K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version_test.go
var errBuf bytes.Buffer for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, c.version), func(t *testing.T) { k8sClient := kube.NewFakeClient() k8sClient.Kube().Discovery().(*fakediscovery.FakeDiscovery).FakedServerVersion = c.version logger := clog.NewConsoleLogger(&outBuf, &errBuf, nil) IsK8VersionSupported(k8sClient, logger) errMsgTrim := strings.TrimSpace(c.logMsg)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 19 02:46:48 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/versiongetter_test.go
wantParsedVersion: "", wantErr: true, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { client := clientsetfake.NewSimpleClientset() client.Discovery().(*fakediscovery.FakeDiscovery).FakedServerVersion = tt.version g := &KubeVersionGetter{ client: client, } clusterVersion, parsedVersion, err := g.ClusterVersion() if (err != nil) != tt.wantErr {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 03 03:03:29 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/versiongetter.go
// via NewClientBackedDryRunGetterFromKubeconfig() and for GetActions there seems to be no analog to // Discovery().Serverversion() resource for a dynamic client(?). fakeclientDiscovery, ok := g.client.Discovery().(*fakediscovery.FakeDiscovery) if ok { clusterVersionInfo = fakeclientDiscovery.FakedServerVersion } else { clusterVersionInfo, err = g.client.Discovery().ServerVersion() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 03 03:03:29 UTC 2024 - 7K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
t.Run(tt.name, func(t *testing.T) { buf := &bytes.Buffer{} client := kube.NewFakeClient(tt.objects...) kube.SetObjectFilter(client, tt.discoveryNamespaceFilter) client.Kube().Discovery().(*fakediscovery.FakeDiscovery).FakedServerVersion = &kubeVersion.Info{Major: "1", Minor: "28"} kclient.NewWriteClient[*k8sbeta.GatewayClass](client).Create(customClass) kclient.NewWriteClient[*k8sbeta.Gateway](client).Create(tt.gw.DeepCopy())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0)