- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 50 for NewNotFound (0.17 sec)
-
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) -
pkg/serviceaccount/claims_test.go
if f.serviceAccount == nil { return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "serviceaccounts"}, name) } return f.serviceAccount, nil } func (f fakeGetter) GetPod(namespace, name string) (*v1.Pod, error) { if f.pod == nil { return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "pods"}, name) } return f.pod, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/registry/registrytest/endpoint.go
if e.Err != nil { return nil, e.Err } if e.Endpoints != nil { for _, endpoint := range e.Endpoints.Items { if endpoint.Name == name { return &endpoint, nil } } } return nil, errors.NewNotFound(api.Resource("endpoints"), name) } func (e *EndpointRegistry) Watch(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error) { return nil, fmt.Errorf("unimplemented!") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 16:50:16 UTC 2019 - 4K bytes - Viewed (0) -
pkg/controller/cronjob/injection.go
func (c *fakeCJControl) GetCronJob(ctx context.Context, namespace, name string) (*batchv1.CronJob, error) { if name == c.CronJob.Name && namespace == c.CronJob.Namespace { return c.CronJob, nil } return nil, errors.NewNotFound(schema.GroupResource{ Group: "v1beta1", Resource: "cronjobs", }, name) } var _ cjControlInterface = &fakeCJControl{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 22 09:37:31 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/registry/core/replicationcontroller/storage/storage.go
} func (r *ScaleREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) { obj, err := r.store.Get(ctx, name, options) if err != nil { return nil, errors.NewNotFound(autoscaling.Resource("replicationcontrollers/scale"), name) } rc := obj.(*api.ReplicationController) return scaleFromRC(rc), nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokengetter.go
} func (c clientGetter) GetNode(name string) (*v1.Node, error) { // handle the case where the node lister isn't set due to feature being disabled if c.nodeLister == nil { return nil, apierrors.NewNotFound(v1.Resource("nodes"), name) } if node, err := c.nodeLister.Get(name); err == nil { return node, nil } return c.client.CoreV1().Nodes().Get(context.TODO(), name, metav1.GetOptions{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 21:15:10 UTC 2023 - 3K bytes - Viewed (0) -
pkg/registry/apps/replicaset/storage/storage.go
func (r *ScaleREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) { obj, err := r.store.Get(ctx, name, options) if err != nil { return nil, errors.NewNotFound(apps.Resource("replicasets/scale"), name) } rs := obj.(*apps.ReplicaSet) scale, err := scaleFromReplicaSet(rs) if err != nil { return nil, errors.NewBadRequest(fmt.Sprintf("%v", err)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/predicates/namespace/matcher_test.go
return nil, nil } func (f fakeNamespaceLister) Get(name string) (*corev1.Namespace, error) { ns, ok := f.namespaces[name] if ok { return ns, nil } return nil, errors.NewNotFound(corev1.Resource("namespaces"), name) } func TestGetNamespaceLabels(t *testing.T) { namespace1Labels := map[string]string{ "runlevel": "1", } namespace1 := corev1.Namespace{ ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 26 00:41:14 UTC 2022 - 4.8K bytes - Viewed (0)