Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for NewNotFound (0.25 sec)

  1. pkg/controlplane/reconcilers/endpointsadapter_test.go

    		},
    		"endpointslice exists, endpoints does not": {
    			expectedError:     errors.NewNotFound(schema.GroupResource{Group: "", Resource: "endpoints"}, "foo"),
    			expectedEndpoints: noEndpoints,
    			initialState:      []runtime.Object{epSlice1},
    			namespaceParam:    "testing",
    			nameParam:         "foo",
    		},
    		"wrong-namespace": {
    			expectedError:     errors.NewNotFound(schema.GroupResource{Group: "", Resource: "endpoints"}, "foo"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. 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)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers_test.go

    			wantBody:    []byte(": bad"),
    		},
    
    		{
    			name:        "fail to encode object or status with status code",
    			out:         smallPayload,
    			outErrs:     []error{kerrors.NewNotFound(schema.GroupResource{}, "test"), fmt.Errorf("bad2")},
    			mediaType:   "application/json",
    			req:         &http.Request{Header: http.Header{}, URL: &url.URL{Path: "/path"}},
    			statusCode:  http.StatusOK,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/cmd/token_test.go

    	var buf bytes.Buffer
    	fakeClient := &fake.Clientset{}
    	fakeClient.AddReactor("get", "secrets", func(action core.Action) (handled bool, ret runtime.Object, err error) {
    		return true, nil, apierrors.NewNotFound(v1.Resource("secrets"), "foo")
    	})
    
    	testCases := []struct {
    		name          string
    		token         string
    		usages        []string
    		extraGroups   []string
    		printJoin     bool
    		expectedError bool
    	}{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 05:47:48 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. pkg/kubelet/util/manager/watch_based_manager.go

    	}
    	obj, exists, err := item.store.GetByKey(c.key(namespace, name))
    	if err != nil {
    		return nil, err
    	}
    	if !exists {
    		return nil, apierrors.NewNotFound(c.groupResource, name)
    	}
    	if object, ok := obj.(runtime.Object); ok {
    		// If the returned object is immutable, stop the reflector.
    		//
    		// NOTE: we may potentially not even start the reflector if the object is
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go

    	return objToUpdate, nil
    }
    
    func (p *jsonPatcher) createNewObject(_ context.Context) (runtime.Object, error) {
    	return nil, errors.NewNotFound(p.resource.GroupResource(), p.name)
    }
    
    type jsonPatchOp struct {
    	Op    string      `json:"op"`
    	Path  string      `json:"path"`
    	From  string      `json:"from"`
    	Value interface{} `json:"value"`
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  7. pkg/controller/testutil/test_utils.go

    			return &nodeCopy, nil
    		}
    	}
    	for i := range m.Existing {
    		if m.Existing[i].Name == name {
    			nodeCopy := *m.Existing[i]
    			return &nodeCopy, nil
    		}
    	}
    	return nil, apierrors.NewNotFound(schema.GroupResource{Resource: "nodes"}, name)
    }
    
    func (m *FakeNodeHandler) runAsyncCalls() {
    	for _, a := range m.AsyncCalls {
    		a(m)
    	}
    }
    
    // List returns a list of Nodes from the fake store.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. plugin/pkg/admission/serviceaccount/admission.go

    		if err == nil {
    			return serviceAccount, nil
    		}
    		if !errors.IsNotFound(err) {
    			return nil, err
    		}
    	}
    
    	return nil, errors.NewNotFound(api.Resource("serviceaccount"), name)
    }
    
    func (s *Plugin) limitSecretReferences(serviceAccount *corev1.ServiceAccount, pod *api.Pod) error {
    	// Ensure all secrets the pod references are allowed by the service account
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  9. pkg/kubelet/util/manager/cache_based_manager_test.go

    		t.Errorf("Unexpected secret: %v", secret)
    	}
    
    	fakeClient.PrependReactor("get", "secrets", func(action core.Action) (bool, runtime.Object, error) {
    		return true, &v1.Secret{}, apierrors.NewNotFound(v1.Resource("secret"), "name")
    	})
    	secret, err = store.Get("ns", "name")
    	if err == nil || !apierrors.IsNotFound(err) {
    		t.Errorf("Unexpected error: %v", err)
    	}
    	if !reflect.DeepEqual(secret, &v1.Secret{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  10. pkg/registry/core/service/strategy_test.go

    )
    
    func TestCheckGeneratedNameError(t *testing.T) {
    	ctx := genericapirequest.WithRequestInfo(genericapirequest.NewContext(), &genericapirequest.RequestInfo{
    		Resource: "foos",
    	})
    
    	expect := errors.NewNotFound(api.Resource("foos"), "bar")
    	if err := rest.CheckGeneratedNameError(ctx, Strategy, expect, &api.Service{}); err != expect {
    		t.Errorf("NotFoundError should be ignored: %v", err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 32.4K bytes
    - Viewed (0)
Back to top