- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for NewNotFound (0.39 sec)
-
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) -
security/pkg/k8s/configutil_test.go
} } func createConfigMapDisabledClient(client *fake.Clientset) { client.PrependReactor("get", "configmaps", func(action ktesting.Action) (bool, runtime.Object, error) { return true, &v1.ConfigMap{}, errors.NewNotFound(v1.Resource("configmaps"), configMapName) }) client.PrependReactor("create", "configmaps", func(action ktesting.Action) (bool, runtime.Object, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 21:58:25 UTC 2024 - 13K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_listers.go
for _, pvc := range f.pvcs { if pvc.Name == name && pvc.Namespace == f.namespace { return pvc, nil } } return nil, errors.NewNotFound(v1.Resource("persistentvolumeclaims"), name) } func (f persistentVolumeClaimNamespaceLister) List(selector labels.Selector) (ret []*v1.PersistentVolumeClaim, err error) { return nil, fmt.Errorf("not implemented") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 20 10:14:08 UTC 2023 - 10.1K bytes - Viewed (0) -
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) -
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) -
cmd/kubeadm/app/util/apiclient/idempotency_test.go
setupClient: func(client *clientsetfake.Clientset) { client.PrependReactor("get", "configmaps", func(clientgotesting.Action) (bool, runtime.Object, error) { return true, nil, apierrors.NewNotFound(schema.GroupResource{}, "name") }) client.PrependReactor("create", "configmaps", func(clientgotesting.Action) (bool, runtime.Object, error) { return true, nil, nil }) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 33.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/errors/errors_test.go
} if !IsConflict(NewConflict(resource("tests"), "2", errors.New("message"))) { t.Errorf("expected to be %s", metav1.StatusReasonAlreadyExists) } if !IsNotFound(NewNotFound(resource("tests"), "3")) { t.Errorf("expected to be %s", metav1.StatusReasonNotFound) } if !IsInvalid(NewInvalid(kind("Test"), "2", nil)) { t.Errorf("expected to be %s", metav1.StatusReasonInvalid) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 28 07:31:28 UTC 2023 - 19.5K bytes - Viewed (0) -
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) -
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) -
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)