- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for NewNotFound (0.29 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/errors/storage.go
// operation into the appropriate API error. func InterpretListError(err error, qualifiedResource schema.GroupResource) error { switch { case storage.IsNotFound(err): return errors.NewNotFound(qualifiedResource, "") case storage.IsUnreachable(err), storage.IsRequestTimeout(err): return errors.NewServerTimeout(qualifiedResource, "list", 2) // TODO: make configurable or handled at a higher level
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 08 15:39:10 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/client/conditions/conditions.go
// returns ErrPodCompleted if the pod has run to completion, or an error in any other case. func PodRunning(event watch.Event) (bool, error) { switch event.Type { case watch.Deleted: return false, errors.NewNotFound(schema.GroupResource{Resource: "pods"}, "") } switch t := event.Object.(type) { case *v1.Pod: switch t.Status.Phase { case v1.PodRunning: return true, nil case v1.PodFailed, v1.PodSucceeded:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 13:43:36 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/fallback_query_param_verifier_test.go
crds: []schema.GroupKind{}, gvk: schema.GroupVersionKind{ Group: "batch", Version: "v1", Kind: "Job", }, queryParam: QueryParamFieldValidation, primaryError: errors.NewNotFound(schema.GroupResource{}, "OpenAPI V3 endpoint not found"), expectedSupports: true, }, "Field validation query param is supported for batch/v1/Job, invalid v3 document error": { crds: []schema.GroupKind{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 18:30:16 UTC 2023 - 10.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter_test.go
}, "endpointslice exists, endpoints does not": { expectedError: errors.NewNotFound(schema.GroupResource{Group: "", Resource: "endpoints"}, "foo"), expectedEndpoints: noEndpoints, initialState: []runtime.Object{epSlice1}, namespaceParam: "testing", nameParam: "foo", }, "wrong-namespace": { expectedError: errors.NewNotFound(schema.GroupResource{Group: "", Resource: "endpoints"}, "foo"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 15.4K bytes - Viewed (0) -
security/pkg/k8s/configutil_test.go
} } func createConfigMapDisabledClient(client *fake.Clientset) { client.PrependReactor("get", "configmaps", func(action ktesting.Action) (bool, runtime.Object, error) { return true, &v1.ConfigMap{}, errors.NewNotFound(v1.Resource("configmaps"), configMapName) }) client.PrependReactor("create", "configmaps", func(action ktesting.Action) (bool, runtime.Object, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 21:58:25 UTC 2024 - 13K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_listers.go
for _, pvc := range f.pvcs { if pvc.Name == name && pvc.Namespace == f.namespace { return pvc, nil } } return nil, errors.NewNotFound(v1.Resource("persistentvolumeclaims"), name) } func (f persistentVolumeClaimNamespaceLister) List(selector labels.Selector) (ret []*v1.PersistentVolumeClaim, err error) { return nil, fmt.Errorf("not implemented") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 20 10:14:08 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/kubelet/certificate/bootstrap/bootstrap_test.go
switch action.GetResource().Version { case "v1": return true, nil, fmt.Errorf("create error") default: return true, nil, apierrors.NewNotFound(certificatesv1.Resource("certificatesigningrequests"), "") } }) default: f.PrependReactor("create", "certificatesigningrequests", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 09 14:24:11 UTC 2023 - 13K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go
{ name: "acquire from no object", reactors: []Reactor{ { verb: "get", reaction: func(action fakeclient.Action) (handled bool, ret runtime.Object, err error) { return true, nil, errors.NewNotFound(action.(fakeclient.GetAction).GetResource().GroupResource(), action.(fakeclient.GetAction).GetName()) }, }, { verb: "create",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 23 16:39:43 UTC 2023 - 42.5K bytes - Viewed (0) -
pkg/registry/registrytest/node.go
r.Lock() defer r.Unlock() if r.Err != nil { return nil, r.Err } for _, node := range r.Nodes.Items { if node.Name == nodeID { return &node, nil } } return nil, errors.NewNotFound(api.Resource("nodes"), nodeID) } func (r *NodeRegistry) DeleteNode(ctx context.Context, nodeID string) error { r.Lock() defer r.Unlock() var newList []api.Node for _, node := range r.Nodes.Items {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 23:13:50 UTC 2024 - 2.8K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/helper_test.go
err: apierrors.NewNotFound(podGVR.GroupResource(), "foo"), opts: metav1.ListOptions{}, subj: podSubject, expectedErr: "Unable to list \"/v1, Resource=pods\": pods \"foo\" not found", expectStatusErr: true, }, { name: "not found StatusError with selectors", err: apierrors.NewNotFound(podGVR.GroupResource(), "foo"), opts: metav1.ListOptions{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 09:47:52 UTC 2023 - 25.2K bytes - Viewed (0)