- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 47 for NewInternalError (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)