Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 47 for NewInternalError (0.2 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/predicates/object/matcher.go

    func (m *Matcher) MatchObjectSelector(p ObjectSelectorProvider, attr admission.Attributes) (bool, *apierrors.StatusError) {
    	selector, err := p.GetParsedObjectSelector()
    	if err != nil {
    		return false, apierrors.NewInternalError(err)
    	}
    	if selector.Empty() {
    		return true, nil
    	}
    	return matchObject(attr.GetObject(), selector) || matchObject(attr.GetOldObject(), selector), nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 26 00:41:14 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook.go

    				m := rules.Matcher{Rule: r, Attr: attrWithOverride}
    				if m.Matches() {
    					kind := o.GetEquivalentResourceMapper().KindFor(equivalent, attr.GetSubresource())
    					if kind.Empty() {
    						return nil, apierrors.NewInternalError(fmt.Errorf("unable to convert to %v: unknown kind", equivalent))
    					}
    					invocation = &WebhookInvocation{
    						Webhook:     h,
    						Resource:    equivalent,
    						Subresource: attr.GetSubresource(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  3. pkg/registry/core/service/storage/alloc.go

    			}
    			if err != nil {
    				return allocated, errors.NewInternalError(fmt.Errorf("failed to allocate a serviceIP: %v", err))
    			}
    			allocated[family] = allocatedIP.String()
    		} else {
    			parsedIP := netutils.ParseIPSloppy(ip)
    			if parsedIP == nil {
    				return allocated, errors.NewInternalError(fmt.Errorf("failed to parse service IP %q", ip))
    			}
    			var err error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 37.3K bytes
    - Viewed (0)
  4. pkg/registry/authentication/tokenreview/storage.go

    	genericapirequest "k8s.io/apiserver/pkg/endpoints/request"
    	"k8s.io/apiserver/pkg/registry/rest"
    	"k8s.io/klog/v2"
    	"k8s.io/kubernetes/pkg/apis/authentication"
    )
    
    var badAuthenticatorAuds = apierrors.NewInternalError(errors.New("error validating audiences"))
    
    type REST struct {
    	tokenAuthenticator authenticator.Request
    	apiAudiences       []string
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 18 09:21:13 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  5. plugin/pkg/admission/podnodeselector/admission.go

    		namespace, err = p.defaultGetNamespace(namespaceName)
    		if err != nil {
    			if errors.IsNotFound(err) {
    				return nil, err
    			}
    			return nil, errors.NewInternalError(err)
    		}
    	} else if err != nil {
    		return nil, errors.NewInternalError(err)
    	}
    
    	return p.getNodeSelectorMap(namespace)
    }
    
    func shouldIgnore(a admission.Attributes) bool {
    	resource := a.GetResource().GroupResource()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  6. plugin/pkg/admission/network/defaultingressclass/admission.go

    	ingress, ok := attr.GetObject().(*networking.Ingress)
    	// if we can't convert then we don't handle this object so just return
    	if !ok {
    		klog.V(3).Infof("Expected Ingress resource, got: %v", attr.GetKind())
    		return errors.NewInternalError(fmt.Errorf("Expected Ingress resource, got: %v", attr.GetKind()))
    	}
    
    	// IngressClassName field has been set, no need to set a default value.
    	if ingress.Spec.IngressClassName != nil {
    		return nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 11 01:48:45 UTC 2022
    - 4.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/update.go

    	var authorizerDecision authorizer.Decision
    	var authorizerReason string
    	var authorizerErr error
    	return func(ctx context.Context, obj runtime.Object) error {
    		if a == nil {
    			return errors.NewInternalError(fmt.Errorf("no authorizer provided, unable to authorize a create on update"))
    		}
    		once.Do(func() {
    			authorizerDecision, authorizerReason, authorizerErr = a.Authorize(ctx, attributes)
    		})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 20:19:46 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/registry/rest/update.go

    		return kerr
    	}
    
    	// ensure namespace on the object is correct, or error if a conflicting namespace was set in the object
    	requestNamespace, ok := genericapirequest.NamespaceFrom(ctx)
    	if !ok {
    		return errors.NewInternalError(fmt.Errorf("no namespace information found in request context"))
    	}
    	if err := EnsureObjectNamespaceMatchesRequestNamespace(ExpectedNamespaceForScope(requestNamespace, strategy.NamespaceScoped()), objectMeta); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 27 11:48:28 UTC 2022
    - 11.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/storage/errors.go

    	return e.Reason
    }
    
    // IsInternalError returns true if and only if err is an InternalError.
    func IsInternalError(err error) bool {
    	_, ok := err.(InternalError)
    	return ok
    }
    
    func NewInternalError(reason string) InternalError {
    	return InternalError{reason}
    }
    
    func NewInternalErrorf(format string, a ...interface{}) InternalError {
    	return InternalError{fmt.Sprintf(format, a...)}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 08 15:39:10 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go

    	}
    	kv := getResp.Kvs[0]
    
    	data, _, err := s.transformer.TransformFromStorage(ctx, kv.Value, authenticatedDataString(preparedKey))
    	if err != nil {
    		return storage.NewInternalError(err.Error())
    	}
    
    	err = decode(s.codec, s.versioner, data, out, kv.ModRevision)
    	if err != nil {
    		recordDecodeError(s.groupResourceString, preparedKey)
    		return err
    	}
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 35.2K bytes
    - Viewed (0)
Back to top