Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for fakediscovery (0.17 sec)

  1. 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)
  2. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/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: Fri Apr 09 06:03:32 UTC 2021
    - 2.7K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top