Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 50 for NewNotFound (0.19 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/matching/matching_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 BenchmarkMatcher(b *testing.B) {
    	allScopes := v1.AllScopes
    	equivalentMatch := v1.Equivalent
    
    	namespace1Labels := map[string]string{"ns": "ns1"}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook_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, k8serrors.NewNotFound(corev1.Resource("namespaces"), name)
    }
    
    func BenchmarkShouldCallHookWithComplexSelector(b *testing.B) {
    	allScopes := v1.AllScopes
    	equivalentMatch := v1.Equivalent
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 28 19:30:04 UTC 2023
    - 32K bytes
    - Viewed (0)
  3. pkg/kubelet/status/status_manager_test.go

    	client := fake.Clientset{}
    	syncer := newTestManager(&client)
    	client.AddReactor("get", "pods", func(action core.Action) (bool, runtime.Object, error) {
    		return true, nil, errors.NewNotFound(api.Resource("pods"), "test-pod")
    	})
    	syncer.SetPodStatus(getTestPod(), getRandomPodStatus())
    	verifyActions(t, syncer, []core.Action{getAction()})
    }
    
    func TestSyncPod(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go

    			continue
    		}
    	}
    }
    
    func TestGetMissing(t *testing.T) {
    	storage := map[string]rest.Storage{}
    	simpleStorage := SimpleRESTStorage{
    		errors: map[string]error{"get": apierrors.NewNotFound(schema.GroupResource{Resource: "simples"}, "id")},
    	}
    	storage["simple"] = &simpleStorage
    	handler := handle(storage)
    	server := httptest.NewServer(handler)
    	defer server.Close()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 20:15:22 UTC 2023
    - 158.7K bytes
    - Viewed (0)
  5. pkg/controller/statefulset/stateful_pod_control_test.go

    	control := NewStatefulPodControl(fakeClient, nil, claimLister, recorder)
    	fakeClient.AddReactor("get", "persistentvolumeclaims", func(action core.Action) (bool, runtime.Object, error) {
    		return true, nil, apierrors.NewNotFound(action.GetResource().GroupResource(), action.GetResource().Resource)
    	})
    	fakeClient.AddReactor("create", "persistentvolumeclaims", func(action core.Action) (bool, runtime.Object, error) {
    		create := action.(core.CreateAction)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
  6. pkg/controller/controller_utils_test.go

    			},
    			nodeName:    "node2",
    			taintsToAdd: []*v1.Taint{{Key: "key2", Value: "value2", Effect: "NoExecute"}},
    			expectedErr: apierrors.NewNotFound(schema.GroupResource{Resource: "nodes"}, "node2"),
    		},
    	}
    	for _, test := range tests {
    		err := AddOrUpdateTaintOnNode(context.TODO(), test.nodeHandler, test.nodeName, test.taintsToAdd...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    	case len(subresource) == 0:
    		handlerFunc = r.serveResource(w, req, requestInfo, crdInfo, crd, terminating, supportedTypes)
    	default:
    		responsewriters.ErrorNegotiated(
    			apierrors.NewNotFound(schema.GroupResource{Group: requestInfo.APIGroup, Resource: requestInfo.Resource}, requestInfo.Name),
    			Codecs, schema.GroupVersion{Group: requestInfo.APIGroup, Version: requestInfo.APIVersion}, w, req,
    		)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
  8. pkg/controller/disruption/disruption_test.go

    				gr := schema.GroupResource{
    					Group:    customGVK.Group,
    					Resource: resourceName,
    				}
    				return true, nil, errors.NewNotFound(gr, "name")
    			})
    			dc.discoveryClient.Resources = []*metav1.APIResourceList{
    				{
    					GroupVersion: customGVK.GroupVersion().String(),
    					APIResources: tc.apiResources,
    				},
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 50K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    		if err != nil {
    			return nil, nil, err
    		}
    		if existingResourceVersion == 0 {
    			if !e.UpdateStrategy.AllowCreateOnUpdate() && !forceAllowCreate {
    				return nil, nil, apierrors.NewNotFound(qualifiedResource, name)
    			}
    		}
    
    		// Given the existing object, get the new object
    		obj, err := objInfo.UpdatedObject(ctx, existing)
    		if err != nil {
    			return nil, nil, err
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet_pods_test.go

    				if tc.configMap == nil {
    					err = apierrors.NewNotFound(action.GetResource().GroupResource(), "configmap-name")
    				}
    				return true, tc.configMap, err
    			})
    			testKubelet.fakeKubeClient.AddReactor("get", "secrets", func(action core.Action) (bool, runtime.Object, error) {
    				var err error
    				if tc.secret == nil {
    					err = apierrors.NewNotFound(action.GetResource().GroupResource(), "secret-name")
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
Back to top