Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewNotFound (0.19 sec)

  1. pkg/kubelet/util/manager/watch_based_manager.go

    	}
    	obj, exists, err := item.store.GetByKey(c.key(namespace, name))
    	if err != nil {
    		return nil, err
    	}
    	if !exists {
    		return nil, apierrors.NewNotFound(c.groupResource, name)
    	}
    	if object, ok := obj.(runtime.Object); ok {
    		// If the returned object is immutable, stop the reflector.
    		//
    		// NOTE: we may potentially not even start the reflector if the object is
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. pkg/kubelet/util/manager/cache_based_manager_test.go

    		t.Errorf("Unexpected secret: %v", secret)
    	}
    
    	fakeClient.PrependReactor("get", "secrets", func(action core.Action) (bool, runtime.Object, error) {
    		return true, &v1.Secret{}, apierrors.NewNotFound(v1.Resource("secret"), "name")
    	})
    	secret, err = store.Get("ns", "name")
    	if err == nil || !apierrors.IsNotFound(err) {
    		t.Errorf("Unexpected error: %v", err)
    	}
    	if !reflect.DeepEqual(secret, &v1.Secret{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_pod_control_test.go

    	control := NewStatefulPodControl(fakeClient, nil, claimLister, recorder)
    	fakeClient.AddReactor("get", "persistentvolumeclaims", func(action core.Action) (bool, runtime.Object, error) {
    		return true, nil, apierrors.NewNotFound(action.GetResource().GroupResource(), action.GetResource().Resource)
    	})
    	fakeClient.AddReactor("create", "persistentvolumeclaims", func(action core.Action) (bool, runtime.Object, error) {
    		create := action.(core.CreateAction)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods_test.go

    				if tc.configMap == nil {
    					err = apierrors.NewNotFound(action.GetResource().GroupResource(), "configmap-name")
    				}
    				return true, tc.configMap, err
    			})
    			testKubelet.fakeKubeClient.AddReactor("get", "secrets", func(action core.Action) (bool, runtime.Object, error) {
    				var err error
    				if tc.secret == nil {
    					err = apierrors.NewNotFound(action.GetResource().GroupResource(), "secret-name")
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
Back to top