Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for InterpretGetError (0.43 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/errors/storage.go

    	case storage.IsInternalError(err):
    		return errors.NewInternalError(err)
    	default:
    		return err
    	}
    }
    
    // InterpretGetError converts a generic error on a retrieval
    // operation into the appropriate API error.
    func InterpretGetError(err error, qualifiedResource schema.GroupResource, name string) error {
    	switch {
    	case storage.IsNotFound(err):
    		return errors.NewNotFound(qualifiedResource, name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 08 15:39:10 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  2. pkg/registry/core/service/allocator/storage/storage.go

    func (e *Etcd) Get() (*api.RangeAllocation, error) {
    	existing := &api.RangeAllocation{}
    	if err := e.storage.Get(context.TODO(), e.baseKey, storage.GetOptions{IgnoreNotFound: true}, existing); err != nil {
    		return nil, storeerr.InterpretGetError(err, e.resource, "")
    	}
    	return existing, nil
    }
    
    // CreateOrUpdate attempts to update the current etcd state with the provided
    // allocation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/etcd.go

    				})
    				return existingCRD, nil
    			}),
    			dryrun.IsDryRun(options.DryRun),
    			nil,
    		)
    
    		if err != nil {
    			err = storageerr.InterpretGetError(err, apiextensions.Resource("customresourcedefinitions"), name)
    			err = storageerr.InterpretUpdateError(err, apiextensions.Resource("customresourcedefinitions"), name)
    			if _, ok := err.(*apierrors.StatusError); !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 18 09:21:19 UTC 2022
    - 8K bytes
    - Viewed (0)
  4. pkg/registry/apps/deployment/storage/storage_test.go

    	}
    	if !apierrors.IsNotFound(storeerr.InterpretGetError(err, apps.Resource("deployments"), name)) {
    		t.Fatalf("Unexpected error returned: %#v", err)
    	}
    
    	_, err = storage.Deployment.Get(ctx, name, &metav1.GetOptions{})
    	if err == nil {
    		t.Fatalf("Expected not-found-error but got nothing")
    	}
    	if !apierrors.IsNotFound(storeerr.InterpretGetError(err, apps.Resource("deployments"), name)) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 07:17:45 UTC 2023
    - 19.7K bytes
    - Viewed (0)
  5. pkg/registry/core/namespace/storage/storage.go

    					}
    					existingNamespace.Finalizers = newFinalizers
    				}
    				return existingNamespace, nil
    			}),
    			dryrun.IsDryRun(options.DryRun),
    			nil,
    		)
    
    		if err != nil {
    			err = storageerr.InterpretGetError(err, api.Resource("namespaces"), name)
    			err = storageerr.InterpretUpdateError(err, api.Resource("namespaces"), name)
    			if _, ok := err.(*apierrors.StatusError); !ok {
    				err = apierrors.NewInternalError(err)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 18 09:21:19 UTC 2022
    - 13.4K bytes
    - Viewed (0)
  6. pkg/registry/core/pod/storage/storage.go

    	if _, err = r.setPodHostAndAnnotations(ctx, podUID, podResourceVersion, podID, machine, annotations, dryRun); err != nil {
    		err = storeerr.InterpretGetError(err, api.Resource("pods"), podID)
    		err = storeerr.InterpretUpdateError(err, api.Resource("pods"), podID)
    		if _, ok := err.(*errors.StatusError); !ok {
    			err = errors.NewConflict(api.Resource("pods/binding"), podID, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 20 14:29:25 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  7. pkg/registry/core/pod/storage/storage_test.go

    	}
    	if !errors.IsNotFound(storeerr.InterpretGetError(err, api.Resource("pods"), "foo")) {
    		t.Fatalf("Unexpected error returned: %#v", err)
    	}
    
    	_, err = storage.Get(ctx, "foo", &metav1.GetOptions{})
    	if err == nil {
    		t.Fatalf("Expected not-found-error but got nothing")
    	}
    	if !errors.IsNotFound(storeerr.InterpretGetError(err, api.Resource("pods"), "foo")) {
    		t.Fatalf("Unexpected error: %v", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 07:18:44 UTC 2024
    - 38.8K bytes
    - Viewed (0)
  8. pkg/registry/apps/deployment/storage/storage.go

    	if _, err := r.setDeploymentRollback(ctx, deploymentID, config, annotations, dryRun); err != nil {
    		err = storeerr.InterpretGetError(err, apps.Resource("deployments"), deploymentID)
    		err = storeerr.InterpretUpdateError(err, apps.Resource("deployments"), deploymentID)
    		if _, ok := err.(*errors.StatusError); !ok {
    			err = errors.NewInternalError(err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 16.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    	key, err := e.KeyFunc(ctx, name)
    	if err != nil {
    		return nil, err
    	}
    	if err := e.Storage.Get(ctx, key, storage.GetOptions{ResourceVersion: options.ResourceVersion}, obj); err != nil {
    		return nil, storeerr.InterpretGetError(err, e.qualifiedResourceFromContext(ctx), name)
    	}
    	if e.Decorator != nil {
    		e.Decorator(obj)
    	}
    	return obj, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
Back to top