- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for NewInternalError (0.19 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/errors/storage.go
return errors.NewServerTimeout(qualifiedResource, "list", 2) // TODO: make configurable or handled at a higher level 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.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 08 15:39:10 UTC 2023 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go
return nil, apierrors.NewInternalError(err) } } else { // Subsequent call, convert existing versioned attributes to the requested version if err := admission.ConvertVersionedAttributes(v.versionedAttr, gvk, v.objectInterfaces); err != nil { return nil, apierrors.NewInternalError(err) } } return v.versionedAttr, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/predicates/namespace/matcher.go
if err != nil { return false, apierrors.NewInternalError(err) } if selector.Empty() { return true, nil } namespaceLabels, err := m.GetNamespaceLabels(attr) // this means the namespace is not found, for backwards compatibility, // return a 404 if apierrors.IsNotFound(err) { status, ok := err.(apierrors.APIStatus) if !ok { return false, apierrors.NewInternalError(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 15 00:53:08 UTC 2023 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/create.go
if !metav1.HasObjectMetaSystemFieldValues(objectMeta) { return errors.NewInternalError(fmt.Errorf("system metadata was not initialized")) } // ensure the name has been generated if len(objectMeta.GetGenerateName()) > 0 && len(objectMeta.GetName()) == 0 { return errors.NewInternalError(fmt.Errorf("metadata.name was not generated")) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 27 11:48:28 UTC 2022 - 9.1K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller_test.go
LongRetry, ) webhooks.Delete(unpatchedWebhookConfig.Name, "") // verify the webhook is updated after the controller can confirm invalid config is rejected. gatewayError.Store(ptr.Of[error](kerrors.NewInternalError(errors.New("unknown error")))) webhooks.Create(unpatchedWebhookConfig) assert.EventuallyEqual( t, fetch(unpatchedWebhookConfig.Name), webhookConfigWithCABundleIgnore,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 05 03:21:04 UTC 2024 - 11.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator.go
if err != nil { websocketStreams.writeStatus(apierrors.NewInternalError(err)) //nolint:errcheck metrics.IncStreamTranslatorRequest(req.Context(), strconv.Itoa(http.StatusInternalServerError)) return } spdyExecutor, err := remotecommand.NewSPDYExecutorRejectRedirects(spdyRoundTripper, spdyRoundTripper, "POST", h.Location) if err != nil { websocketStreams.writeStatus(apierrors.NewInternalError(err)) //nolint:errcheck
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 6.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go
} var ( exists bool err error ) namespace, err := l.namespaceLister.Get(a.GetNamespace()) if err != nil { if !errors.IsNotFound(err) { return errors.NewInternalError(err) } } else { exists = true } if !exists && a.GetOperation() == admission.Create { // give the cache time to observe the namespace before rejecting a create.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 8.6K bytes - Viewed (0) -
pkg/config/analysis/local/analyze_test.go
g := NewWithT(t) cancel := make(chan struct{}) r1 := createTestResource(t, "ns1", "resource", "v1") r2 := createTestResource(t, "ns2", "resource", "v1") msg1 := msg.NewInternalError(r1, "msg") msg2 := msg.NewInternalError(r2, "msg") a := &testAnalyzer{ fn: func(ctx analysis.Context) { ctx.Report(K8SCollection1.GroupVersionKind(), msg1) ctx.Report(K8SCollection1.GroupVersionKind(), msg2) }, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 09 07:43:43 UTC 2024 - 9.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go
// VersionedAttr result will be cached and reused later during parallel webhook calls _, err := versionedAttrAccessor.VersionedAttribute(invocation.Kind) if err != nil { return apierrors.NewInternalError(err) } } if len(relevantHooks) == 0 { // no matching hooks return nil } // Check if the request has already timed out before spawning remote calls select {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 20:24:12 UTC 2023 - 13K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control_test.go
control := NewStatefulPodControl(fakeClient, nil, pvcLister, recorder) fakeClient.AddReactor("create", "persistentvolumeclaims", func(action core.Action) (bool, runtime.Object, error) { return true, nil, apierrors.NewInternalError(errors.New("API server down")) }) fakeClient.AddReactor("create", "pods", func(action core.Action) (bool, runtime.Object, error) { create := action.(core.CreateAction) return true, create.GetObject(), nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0)