- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 50 for NewNotFound (0.94 sec)
-
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) -
pkg/controller/namespace/deletion/namespaced_resources_deleter_test.go
if action.GetNamespace() == "ns1" { // simulate the flakes resource not existing when ns1 is processed return true, nil, errors.NewNotFound(schema.GroupResource{}, "") } return false, nil, nil } mockMetadataClient := metadatafake.NewSimpleMetadataClient(metadatafake.NewTestScheme())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 07:34:23 UTC 2023 - 15.8K 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) -
pkg/registry/apps/statefulset/storage/storage.go
} // if zero-value, the existing object does not exist if len(statefulset.ResourceVersion) == 0 { return nil, errors.NewNotFound(apps.Resource("statefulsets/scale"), i.name) } groupVersion := schema.GroupVersion{Group: "apps", Version: "v1"} if requestInfo, found := genericapirequest.RequestInfoFrom(ctx); found {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.7K bytes - Viewed (0) -
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) -
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) -
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) -
pkg/controller/history/controller_history_test.go
test.revision.Namespace == test.existing[i].revision.Namespace { found = test.existing[i].revision break } } if found == nil { return true, nil, errors.NewNotFound(apps.Resource("controllerrevisions"), test.revision.Name) } b, err := strategicpatch.StrategicMergePatch( []byte(runtime.EncodeOrDie(clientscheme.Codecs.LegacyCodec(apps.SchemeGroupVersion), test.revision)),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 49.1K bytes - Viewed (0) -
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)