Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 50 for NewNotFound (0.6 sec)

  1. pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go

    		{
    			name: "acquire from no object",
    			reactors: []Reactor{
    				{
    					verb: "get",
    					reaction: func(action fakeclient.Action) (handled bool, ret runtime.Object, err error) {
    						return true, nil, errors.NewNotFound(action.(fakeclient.GetAction).GetResource().GroupResource(), action.(fakeclient.GetAction).GetName())
    					},
    				},
    				{
    					verb: "create",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jan 23 16:39:43 UTC 2023
    - 42.5K bytes
    - Viewed (0)
  2. pkg/registry/registrytest/node.go

    	r.Lock()
    	defer r.Unlock()
    	if r.Err != nil {
    		return nil, r.Err
    	}
    	for _, node := range r.Nodes.Items {
    		if node.Name == nodeID {
    			return &node, nil
    		}
    	}
    	return nil, errors.NewNotFound(api.Resource("nodes"), nodeID)
    }
    
    func (r *NodeRegistry) DeleteNode(ctx context.Context, nodeID string) error {
    	r.Lock()
    	defer r.Unlock()
    	var newList []api.Node
    	for _, node := range r.Nodes.Items {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 23:13:50 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/cli-runtime/pkg/resource/helper_test.go

    			err:             apierrors.NewNotFound(podGVR.GroupResource(), "foo"),
    			opts:            metav1.ListOptions{},
    			subj:            podSubject,
    			expectedErr:     "Unable to list \"/v1, Resource=pods\": pods \"foo\" not found",
    			expectStatusErr: true,
    		}, {
    			name: "not found StatusError with selectors",
    			err:  apierrors.NewNotFound(podGVR.GroupResource(), "foo"),
    			opts: metav1.ListOptions{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 02 09:47:52 UTC 2023
    - 25.2K bytes
    - Viewed (0)
  4. pkg/serviceaccount/claims_test.go

    	if f.serviceAccount == nil {
    		return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "serviceaccounts"}, name)
    	}
    	return f.serviceAccount, nil
    }
    func (f fakeGetter) GetPod(namespace, name string) (*v1.Pod, error) {
    	if f.pod == nil {
    		return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "pods"}, name)
    	}
    	return f.pod, nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  5. pkg/registry/registrytest/endpoint.go

    	if e.Err != nil {
    		return nil, e.Err
    	}
    	if e.Endpoints != nil {
    		for _, endpoint := range e.Endpoints.Items {
    			if endpoint.Name == name {
    				return &endpoint, nil
    			}
    		}
    	}
    	return nil, errors.NewNotFound(api.Resource("endpoints"), name)
    }
    
    func (e *EndpointRegistry) Watch(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error) {
    	return nil, fmt.Errorf("unimplemented!")
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 16:50:16 UTC 2019
    - 4K bytes
    - Viewed (0)
  6. pkg/controller/cronjob/injection.go

    func (c *fakeCJControl) GetCronJob(ctx context.Context, namespace, name string) (*batchv1.CronJob, error) {
    	if name == c.CronJob.Name && namespace == c.CronJob.Namespace {
    		return c.CronJob, nil
    	}
    	return nil, errors.NewNotFound(schema.GroupResource{
    		Group:    "v1beta1",
    		Resource: "cronjobs",
    	}, name)
    }
    
    var _ cjControlInterface = &fakeCJControl{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 22 09:37:31 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  7. pkg/registry/core/replicationcontroller/storage/storage.go

    }
    
    func (r *ScaleREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) {
    	obj, err := r.store.Get(ctx, name, options)
    	if err != nil {
    		return nil, errors.NewNotFound(autoscaling.Resource("replicationcontrollers/scale"), name)
    	}
    	rc := obj.(*api.ReplicationController)
    	return scaleFromRC(rc), nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 12K bytes
    - Viewed (0)
  8. pkg/controller/serviceaccount/tokengetter.go

    }
    
    func (c clientGetter) GetNode(name string) (*v1.Node, error) {
    	// handle the case where the node lister isn't set due to feature being disabled
    	if c.nodeLister == nil {
    		return nil, apierrors.NewNotFound(v1.Resource("nodes"), name)
    	}
    	if node, err := c.nodeLister.Get(name); err == nil {
    		return node, nil
    	}
    	return c.client.CoreV1().Nodes().Get(context.TODO(), name, metav1.GetOptions{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 21:15:10 UTC 2023
    - 3K bytes
    - Viewed (0)
  9. pkg/registry/apps/replicaset/storage/storage.go

    func (r *ScaleREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) {
    	obj, err := r.store.Get(ctx, name, options)
    	if err != nil {
    		return nil, errors.NewNotFound(apps.Resource("replicasets/scale"), name)
    	}
    	rs := obj.(*apps.ReplicaSet)
    	scale, err := scaleFromReplicaSet(rs)
    	if err != nil {
    		return nil, errors.NewBadRequest(fmt.Sprintf("%v", err))
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 12.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/predicates/namespace/matcher_test.go

    	return nil, nil
    }
    func (f fakeNamespaceLister) Get(name string) (*corev1.Namespace, error) {
    	ns, ok := f.namespaces[name]
    	if ok {
    		return ns, nil
    	}
    	return nil, errors.NewNotFound(corev1.Resource("namespaces"), name)
    }
    
    func TestGetNamespaceLabels(t *testing.T) {
    	namespace1Labels := map[string]string{
    		"runlevel": "1",
    	}
    	namespace1 := corev1.Namespace{
    		ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 26 00:41:14 UTC 2022
    - 4.8K bytes
    - Viewed (0)
Back to top