diff --git a/staging/src/k8s.io/kubectl/pkg/cmd/wait/wait.go b/staging/src/k8s.io/kubectl/pkg/cmd/wait/wait.go index 83ca3fc910e..175cf442487 100644 --- a/staging/src/k8s.io/kubectl/pkg/cmd/wait/wait.go +++ b/staging/src/k8s.io/kubectl/pkg/cmd/wait/wait.go @@ -40,11 +40,13 @@ import ( "k8s.io/cli-runtime/pkg/printers" "k8s.io/cli-runtime/pkg/resource" "k8s.io/client-go/dynamic" + "k8s.io/client-go/tools/cache" watchtools "k8s.io/client-go/tools/watch" "k8s.io/client-go/util/jsonpath" cmdget "k8s.io/kubectl/pkg/cmd/get" cmdutil "k8s.io/kubectl/pkg/cmd/util" "k8s.io/kubectl/pkg/util/i18n" + "k8s.io/kubectl/pkg/util/interrupt" "k8s.io/kubectl/pkg/util/templates" ) @@ -317,70 +319,86 @@ func (o *WaitOptions) RunWait() error { // IsDeleted is a condition func for waiting for something to be deleted func IsDeleted(info *resource.Info, o *WaitOptions) (runtime.Object, bool, error) { - endTime := time.Now().Add(o.Timeout) - for { - if len(info.Name) == 0 { - return info.Object, false, fmt.Errorf("resource name must be provided") - } + if len(info.Name) == 0 { + return info.Object, false, fmt.Errorf("resource name must be provided") + } - nameSelector := fields.OneTermEqualSelector("metadata.name", info.Name).String() - - // List with a name field selector to get the current resourceVersion to watch from (not the object's resourceVersion) - gottenObjList, err := o.DynamicClient.Resource(info.Mapping.Resource).Namespace(info.Namespace).List(context.TODO(), metav1.ListOptions{FieldSelector: nameSelector}) - if apierrors.IsNotFound(err) { - return info.Object, true, nil - } - if err != nil { - // TODO this could do something slightly fancier if we wish - return info.Object, false, err - } - if len(gottenObjList.Items) != 1 { - return info.Object, true, nil - } - gottenObj := &gottenObjList.Items[0] - resourceLocation := ResourceLocation{ - GroupResource: info.Mapping.Resource.GroupResource(), - Namespace: gottenObj.GetNamespace(), - Name: gottenObj.GetName(), - } - if uid, ok := o.UIDMap[resourceLocation]; ok { - if gottenObj.GetUID() != uid { - return gottenObj, true, nil - } - } - - watchOptions := metav1.ListOptions{} - watchOptions.FieldSelector = nameSelector - watchOptions.ResourceVersion = gottenObjList.GetResourceVersion() - objWatch, err := o.DynamicClient.Resource(info.Mapping.Resource).Namespace(info.Namespace).Watch(context.TODO(), watchOptions) - if err != nil { - return gottenObj, false, err - } - - timeout := endTime.Sub(time.Now()) - errWaitTimeoutWithName := extendErrWaitTimeout(wait.ErrWaitTimeout, info) - if timeout < 0 { - // we're out of time - return gottenObj, false, errWaitTimeoutWithName - } - - ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout) - watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, Wait{errOut: o.ErrOut}.IsDeleted) - cancel() - switch { - case err == nil: - return watchEvent.Object, true, nil - case err == watchtools.ErrWatchClosed: - continue - case err == wait.ErrWaitTimeout: - if watchEvent != nil { - return watchEvent.Object, false, errWaitTimeoutWithName - } - return gottenObj, false, errWaitTimeoutWithName - default: - return gottenObj, false, err + gottenObj, initObjGetErr := o.DynamicClient.Resource(info.Mapping.Resource).Namespace(info.Namespace).Get(context.Background(), info.Name, metav1.GetOptions{}) + if apierrors.IsNotFound(initObjGetErr) { + return info.Object, true, nil + } + if initObjGetErr != nil { + // TODO this could do something slightly fancier if we wish + return info.Object, false, initObjGetErr + } + resourceLocation := ResourceLocation{ + GroupResource: info.Mapping.Resource.GroupResource(), + Namespace: gottenObj.GetNamespace(), + Name: gottenObj.GetName(), + } + if uid, ok := o.UIDMap[resourceLocation]; ok { + if gottenObj.GetUID() != uid { + return gottenObj, true, nil } } + + endTime := time.Now().Add(o.Timeout) + timeout := time.Until(endTime) + errWaitTimeoutWithName := extendErrWaitTimeout(wait.ErrWaitTimeout, info) + if o.Timeout == 0 { + // If timeout is zero check if the object exists once only + if gottenObj == nil { + return nil, true, nil + } + return gottenObj, false, fmt.Errorf("condition not met for %s", info.ObjectName()) + } + if timeout < 0 { + // we're out of time + return info.Object, false, errWaitTimeoutWithName + } + + ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout) + defer cancel() + + fieldSelector := fields.OneTermEqualSelector("metadata.name", info.Name).String() + lw := &cache.ListWatch{ + ListFunc: func(options metav1.ListOptions) (runtime.Object, error) { + options.FieldSelector = fieldSelector + return o.DynamicClient.Resource(info.Mapping.Resource).Namespace(info.Namespace).List(context.TODO(), options) + }, + WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) { + options.FieldSelector = fieldSelector + return o.DynamicClient.Resource(info.Mapping.Resource).Namespace(info.Namespace).Watch(context.TODO(), options) + }, + } + + // this function is used to refresh the cache to prevent timeout waits on resources that have disappeared + preconditionFunc := func(store cache.Store) (bool, error) { + _, exists, err := store.Get(&metav1.ObjectMeta{Namespace: info.Namespace, Name: info.Name}) + if err != nil { + return true, err + } + if !exists { + // since we're looking for it to disappear we just return here if it no longer exists + return true, nil + } + + return false, nil + } + + intr := interrupt.New(nil, cancel) + err := intr.Run(func() error { + _, err := watchtools.UntilWithSync(ctx, lw, &unstructured.Unstructured{}, preconditionFunc, Wait{errOut: o.ErrOut}.IsDeleted) + return err + }) + if err != nil { + if err == wait.ErrWaitTimeout { + return gottenObj, false, errWaitTimeoutWithName + } + return gottenObj, false, err + } + + return gottenObj, true, nil } // Wait has helper methods for handling watches, including error handling. @@ -410,68 +428,85 @@ type checkCondFunc func(obj *unstructured.Unstructured) (bool, error) // getObjAndCheckCondition will make a List query to the API server to get the object and check if the condition is met using check function. // If the condition is not met, it will make a Watch query to the server and pass in the condMet function func getObjAndCheckCondition(info *resource.Info, o *WaitOptions, condMet isCondMetFunc, check checkCondFunc) (runtime.Object, bool, error) { + if len(info.Name) == 0 { + return info.Object, false, fmt.Errorf("resource name must be provided") + } + endTime := time.Now().Add(o.Timeout) - for { - if len(info.Name) == 0 { - return info.Object, false, fmt.Errorf("resource name must be provided") + timeout := time.Until(endTime) + errWaitTimeoutWithName := extendErrWaitTimeout(wait.ErrWaitTimeout, info) + if o.Timeout == 0 { + // If timeout is zero we will fetch the object(s) once only and check + gottenObj, initObjGetErr := o.DynamicClient.Resource(info.Mapping.Resource).Namespace(info.Namespace).Get(context.Background(), info.Name, metav1.GetOptions{}) + if initObjGetErr != nil { + return nil, false, initObjGetErr } - - nameSelector := fields.OneTermEqualSelector("metadata.name", info.Name).String() - - var gottenObj *unstructured.Unstructured - // List with a name field selector to get the current resourceVersion to watch from (not the object's resourceVersion) - gottenObjList, err := o.DynamicClient.Resource(info.Mapping.Resource).Namespace(info.Namespace).List(context.TODO(), metav1.ListOptions{FieldSelector: nameSelector}) - - resourceVersion := "" - switch { - case err != nil: - return info.Object, false, err - case len(gottenObjList.Items) != 1: - resourceVersion = gottenObjList.GetResourceVersion() - default: - gottenObj = &gottenObjList.Items[0] - conditionMet, err := check(gottenObj) - if conditionMet { - return gottenObj, true, nil - } - if err != nil { - return gottenObj, false, err - } - resourceVersion = gottenObjList.GetResourceVersion() + if gottenObj == nil { + return nil, false, fmt.Errorf("condition not met for %s", info.ObjectName()) } - - watchOptions := metav1.ListOptions{} - watchOptions.FieldSelector = nameSelector - watchOptions.ResourceVersion = resourceVersion - objWatch, err := o.DynamicClient.Resource(info.Mapping.Resource).Namespace(info.Namespace).Watch(context.TODO(), watchOptions) + conditionCheck, err := check(gottenObj) if err != nil { return gottenObj, false, err } - - timeout := endTime.Sub(time.Now()) - errWaitTimeoutWithName := extendErrWaitTimeout(wait.ErrWaitTimeout, info) - if timeout < 0 { - // we're out of time - return gottenObj, false, errWaitTimeoutWithName - } - - ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout) - watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, watchtools.ConditionFunc(condMet)) - cancel() - switch { - case err == nil: - return watchEvent.Object, true, nil - case err == watchtools.ErrWatchClosed: - continue - case err == wait.ErrWaitTimeout: - if watchEvent != nil { - return watchEvent.Object, false, errWaitTimeoutWithName - } - return gottenObj, false, errWaitTimeoutWithName - default: - return gottenObj, false, err + if conditionCheck == false { + return gottenObj, false, fmt.Errorf("condition not met for %s", info.ObjectName()) } + return gottenObj, true, nil } + if timeout < 0 { + // we're out of time + return info.Object, false, errWaitTimeoutWithName + } + + ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout) + defer cancel() + + mapping := info.ResourceMapping() // used to pass back meaningful errors if object disappears + fieldSelector := fields.OneTermEqualSelector("metadata.name", info.Name).String() + lw := &cache.ListWatch{ + ListFunc: func(options metav1.ListOptions) (runtime.Object, error) { + options.FieldSelector = fieldSelector + return o.DynamicClient.Resource(info.Mapping.Resource).Namespace(info.Namespace).List(context.TODO(), options) + }, + WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) { + options.FieldSelector = fieldSelector + return o.DynamicClient.Resource(info.Mapping.Resource).Namespace(info.Namespace).Watch(context.TODO(), options) + }, + } + + // this function is used to refresh the cache to prevent timeout waits on resources that have disappeared + preconditionFunc := func(store cache.Store) (bool, error) { + _, exists, err := store.Get(&metav1.ObjectMeta{Namespace: info.Namespace, Name: info.Name}) + if err != nil { + return true, err + } + if !exists { + return true, apierrors.NewNotFound(mapping.Resource.GroupResource(), info.Name) + } + + return false, nil + } + + var result runtime.Object + intr := interrupt.New(nil, cancel) + err := intr.Run(func() error { + ev, err := watchtools.UntilWithSync(ctx, lw, &unstructured.Unstructured{}, preconditionFunc, watchtools.ConditionFunc(condMet)) + if ev != nil { + result = ev.Object + } + if err == context.DeadlineExceeded { + return errWaitTimeoutWithName + } + return err + }) + if err != nil { + if err == wait.ErrWaitTimeout { + return result, false, errWaitTimeoutWithName + } + return result, false, err + } + + return result, true, nil } // ConditionalWait hold information to check an API status condition diff --git a/staging/src/k8s.io/kubectl/pkg/cmd/wait/wait_test.go b/staging/src/k8s.io/kubectl/pkg/cmd/wait/wait_test.go index 94e4a24fe80..3bb28e09683 100644 --- a/staging/src/k8s.io/kubectl/pkg/cmd/wait/wait_test.go +++ b/staging/src/k8s.io/kubectl/pkg/cmd/wait/wait_test.go @@ -276,8 +276,9 @@ func TestWaitForDeletion(t *testing.T) { if len(actions) != 1 { t.Fatal(spew.Sdump(actions)) } - if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { - t.Error(spew.Sdump(actions)) + + if !actions[0].Matches("get", "theresource") || actions[0].(clienttesting.GetAction).GetName() != "name-foo" { + t.Error(spew.Sdump(actions[0])) } }, }, @@ -318,7 +319,7 @@ func TestWaitForDeletion(t *testing.T) { count++ fakeWatch := watch.NewRaceFreeFake() go func() { - time.Sleep(100 * time.Millisecond) + time.Sleep(1 * time.Second) fakeWatch.Stop() }() return true, fakeWatch, nil @@ -338,7 +339,7 @@ func TestWaitForDeletion(t *testing.T) { if len(actions) != 1 { t.Fatal(spew.Sdump(actions)) } - if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { + if !actions[0].Matches("get", "theresource") || actions[0].(clienttesting.GetAction).GetName() != "name-foo" { t.Error(spew.Sdump(actions)) } }, @@ -356,6 +357,9 @@ func TestWaitForDeletion(t *testing.T) { }, fakeClient: func() *dynamicfakeclient.FakeDynamicClient { fakeClient := dynamicfakeclient.NewSimpleDynamicClientWithCustomListKinds(scheme, listMapping) + fakeClient.PrependReactor("get", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { + return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil + }) fakeClient.PrependReactor("list", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil }) @@ -365,17 +369,72 @@ func TestWaitForDeletion(t *testing.T) { expectedErr: "timed out waiting for the condition on theresource/name-foo", validateActions: func(t *testing.T, actions []clienttesting.Action) { - if len(actions) != 2 { + if len(actions) != 3 { t.Fatal(spew.Sdump(actions)) } - if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { + if !actions[0].Matches("get", "theresource") || actions[0].(clienttesting.GetAction).GetName() != "name-foo" { t.Error(spew.Sdump(actions)) } - if !actions[1].Matches("watch", "theresource") { + if !actions[1].Matches("list", "theresource") || actions[1].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { + t.Error(spew.Sdump(actions)) + } + if !actions[2].Matches("watch", "theresource") || actions[2].(clienttesting.WatchAction).GetWatchRestrictions().Fields.String() != "metadata.name=name-foo" { t.Error(spew.Sdump(actions)) } }, }, + { + name: "delete for existing resource with no timeout", + infos: []*resource.Info{ + { + Mapping: &meta.RESTMapping{ + Resource: schema.GroupVersionResource{Group: "group", Version: "version", Resource: "theresource"}, + }, + Name: "name-foo", + Namespace: "ns-foo", + }, + }, + fakeClient: func() *dynamicfakeclient.FakeDynamicClient { + fakeClient := dynamicfakeclient.NewSimpleDynamicClientWithCustomListKinds(scheme, listMapping) + fakeClient.PrependReactor("get", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { + return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil + }) + fakeClient.PrependReactor("list", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { + return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil + }) + return fakeClient + }, + timeout: 0 * time.Second, + + expectedErr: "condition not met for theresource/name-foo", + validateActions: nil, + }, + { + name: "delete for nonexisting resource with no timeout", + infos: []*resource.Info{ + { + Mapping: &meta.RESTMapping{ + Resource: schema.GroupVersionResource{Group: "group", Version: "version", Resource: "thenonexistentresource"}, + }, + Name: "name-foo", + Namespace: "ns-foo", + }, + }, + fakeClient: func() *dynamicfakeclient.FakeDynamicClient { + fakeClient := dynamicfakeclient.NewSimpleDynamicClientWithCustomListKinds(scheme, listMapping) + fakeClient.PrependReactor("get", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { + return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil + }) + fakeClient.PrependReactor("list", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { + return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil + }) + return fakeClient + }, + timeout: 0 * time.Second, + + expectedErr: "", + validateActions: nil, + }, { name: "handles watch close out", infos: []*resource.Info{ @@ -389,6 +448,13 @@ func TestWaitForDeletion(t *testing.T) { }, fakeClient: func() *dynamicfakeclient.FakeDynamicClient { fakeClient := dynamicfakeclient.NewSimpleDynamicClientWithCustomListKinds(scheme, listMapping) + fakeClient.PrependReactor("get", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { + unstructuredObj := newUnstructured("group/version", "TheKind", "ns-foo", "name-foo") + unstructuredObj.SetResourceVersion("123") + unstructuredList := newUnstructuredList(unstructuredObj) + unstructuredList.SetResourceVersion("234") + return true, unstructuredList, nil + }) fakeClient.PrependReactor("list", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { unstructuredObj := newUnstructured("group/version", "TheKind", "ns-foo", "name-foo") unstructuredObj.SetResourceVersion("123") @@ -402,7 +468,7 @@ func TestWaitForDeletion(t *testing.T) { count++ fakeWatch := watch.NewRaceFreeFake() go func() { - time.Sleep(100 * time.Millisecond) + time.Sleep(1 * time.Second) fakeWatch.Stop() }() return true, fakeWatch, nil @@ -419,17 +485,17 @@ func TestWaitForDeletion(t *testing.T) { if len(actions) != 4 { t.Fatal(spew.Sdump(actions)) } - if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { - t.Error(spew.Sdump(actions)) + if !actions[0].Matches("get", "theresource") || actions[0].(clienttesting.GetAction).GetName() != "name-foo" { + t.Error(spew.Sdump(actions[0])) } - if !actions[1].Matches("watch", "theresource") || actions[1].(clienttesting.WatchAction).GetWatchRestrictions().ResourceVersion != "234" { - t.Error(spew.Sdump(actions)) + if !actions[1].Matches("list", "theresource") || actions[1].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { + t.Error(spew.Sdump(actions[1])) } - if !actions[2].Matches("list", "theresource") || actions[2].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { - t.Error(spew.Sdump(actions)) + if !actions[2].Matches("watch", "theresource") || actions[2].(clienttesting.WatchAction).GetWatchRestrictions().ResourceVersion != "234" { + t.Error(spew.Sdump(actions[2])) } if !actions[3].Matches("watch", "theresource") || actions[3].(clienttesting.WatchAction).GetWatchRestrictions().ResourceVersion != "234" { - t.Error(spew.Sdump(actions)) + t.Error(spew.Sdump(actions[3])) } }, }, @@ -459,13 +525,10 @@ func TestWaitForDeletion(t *testing.T) { timeout: 10 * time.Second, validateActions: func(t *testing.T, actions []clienttesting.Action) { - if len(actions) != 2 { + if len(actions) != 1 { t.Fatal(spew.Sdump(actions)) } - if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { - t.Error(spew.Sdump(actions)) - } - if !actions[1].Matches("watch", "theresource") { + if !actions[0].Matches("get", "theresource") || actions[0].(clienttesting.GetAction).GetName() != "name-foo" { t.Error(spew.Sdump(actions)) } }, @@ -511,14 +574,26 @@ func TestWaitForDeletion(t *testing.T) { timeout: 10 * time.Second, validateActions: func(t *testing.T, actions []clienttesting.Action) { - if len(actions) != 2 { + if len(actions) != 6 { t.Fatal(spew.Sdump(actions)) } - if !actions[0].Matches("list", "theresource-1") { - t.Error(spew.Sdump(actions)) + if !actions[0].Matches("get", "theresource-1") || actions[0].(clienttesting.GetAction).GetName() != "name-foo-1" { + t.Error(spew.Sdump(actions[0])) } - if !actions[1].Matches("list", "theresource-2") { - t.Error(spew.Sdump(actions)) + if !actions[1].Matches("list", "theresource-1") || actions[1].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo-1" { + t.Error(spew.Sdump(actions[1])) + } + if !actions[2].Matches("watch", "theresource-1") || actions[2].(clienttesting.WatchAction).GetWatchRestrictions().Fields.String() != "metadata.name=name-foo-1" { + t.Error(spew.Sdump(actions[2])) + } + if !actions[3].Matches("get", "theresource-2") || actions[3].(clienttesting.GetAction).GetName() != "name-foo-2" { + t.Error(spew.Sdump(actions[3])) + } + if !actions[4].Matches("list", "theresource-2") || actions[4].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo-2" { + t.Error(spew.Sdump(actions[4])) + } + if !actions[5].Matches("watch", "theresource-2") || actions[5].(clienttesting.WatchAction).GetWatchRestrictions().Fields.String() != "metadata.name=name-foo-2" { + t.Error(spew.Sdump(actions[5])) } }, }, @@ -560,19 +635,10 @@ func TestWaitForDeletion(t *testing.T) { timeout: 10 * time.Second, validateActions: func(t *testing.T, actions []clienttesting.Action) { - if len(actions) != 4 { + if len(actions) != 1 { t.Fatal(spew.Sdump(actions)) } - if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { - t.Error(spew.Sdump(actions)) - } - if !actions[1].Matches("watch", "theresource") { - t.Error(spew.Sdump(actions)) - } - if !actions[2].Matches("list", "theresource") || actions[2].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { - t.Error(spew.Sdump(actions)) - } - if !actions[3].Matches("watch", "theresource") { + if !actions[0].Matches("get", "theresource") || actions[0].(clienttesting.GetAction).GetName() != "name-foo" { t.Error(spew.Sdump(actions)) } }, @@ -605,7 +671,9 @@ func TestWaitForDeletion(t *testing.T) { } } - test.validateActions(t, fakeClient.Actions()) + if test.validateActions != nil { + test.validateActions(t, fakeClient.Actions()) + } }) } } @@ -649,10 +717,14 @@ func TestWaitForCondition(t *testing.T) { timeout: 10 * time.Second, validateActions: func(t *testing.T, actions []clienttesting.Action) { - if len(actions) != 1 { + if len(actions) != 2 { t.Fatal(spew.Sdump(actions)) } - if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { + if !actions[0].Matches("list", "theresource") { + t.Error(spew.Sdump(actions)) + } else if actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { + t.Error(spew.Sdump(actions)) + } else if actions[1].(clienttesting.WatchAction).GetWatchRestrictions().Fields.String() != "metadata.name=name-foo" { t.Error(spew.Sdump(actions)) } }, @@ -717,7 +789,7 @@ func TestWaitForCondition(t *testing.T) { }, timeout: 1 * time.Second, - expectedErr: "timed out waiting for the condition on theresource/name-foo", + expectedErr: `theresource.group "name-foo" not found`, validateActions: func(t *testing.T, actions []clienttesting.Action) { if len(actions) != 2 { t.Fatal(spew.Sdump(actions)) @@ -730,6 +802,58 @@ func TestWaitForCondition(t *testing.T) { } }, }, + { + name: "for nonexisting resource with no timeout", + infos: []*resource.Info{ + { + Mapping: &meta.RESTMapping{ + Resource: schema.GroupVersionResource{Group: "group", Version: "version", Resource: "thenonexistingresource"}, + }, + Name: "name-foo", + Namespace: "ns-foo", + }, + }, + fakeClient: func() *dynamicfakeclient.FakeDynamicClient { + fakeClient := dynamicfakeclient.NewSimpleDynamicClientWithCustomListKinds(scheme, listMapping) + fakeClient.PrependReactor("get", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { + return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil + }) + fakeClient.PrependReactor("list", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { + return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil + }) + return fakeClient + }, + timeout: 0 * time.Second, + + expectedErr: "thenonexistingresource.group \"name-foo\" not found", + validateActions: nil, + }, + { + name: "for existing resource with no timeout", + infos: []*resource.Info{ + { + Mapping: &meta.RESTMapping{ + Resource: schema.GroupVersionResource{Group: "group", Version: "version", Resource: "theresource"}, + }, + Name: "name-foo", + Namespace: "ns-foo", + }, + }, + fakeClient: func() *dynamicfakeclient.FakeDynamicClient { + fakeClient := dynamicfakeclient.NewSimpleDynamicClientWithCustomListKinds(scheme, listMapping) + fakeClient.PrependReactor("get", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { + return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil + }) + fakeClient.PrependReactor("list", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { + return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil + }) + return fakeClient + }, + timeout: 0 * time.Second, + + expectedErr: "condition not met for theresource/name-foo", + validateActions: nil, + }, { name: "handles watch close out", infos: []*resource.Info{ @@ -756,7 +880,7 @@ func TestWaitForCondition(t *testing.T) { count++ fakeWatch := watch.NewRaceFreeFake() go func() { - time.Sleep(100 * time.Millisecond) + time.Sleep(1 * time.Second) fakeWatch.Stop() }() return true, fakeWatch, nil @@ -770,7 +894,7 @@ func TestWaitForCondition(t *testing.T) { expectedErr: "timed out waiting for the condition on theresource/name-foo", validateActions: func(t *testing.T, actions []clienttesting.Action) { - if len(actions) != 4 { + if len(actions) != 3 { t.Fatal(spew.Sdump(actions)) } if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { @@ -779,10 +903,7 @@ func TestWaitForCondition(t *testing.T) { if !actions[1].Matches("watch", "theresource") || actions[1].(clienttesting.WatchAction).GetWatchRestrictions().ResourceVersion != "234" { t.Error(spew.Sdump(actions)) } - if !actions[2].Matches("list", "theresource") || actions[2].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=name-foo" { - t.Error(spew.Sdump(actions)) - } - if !actions[3].Matches("watch", "theresource") || actions[3].(clienttesting.WatchAction).GetWatchRestrictions().ResourceVersion != "234" { + if !actions[2].Matches("watch", "theresource") || actions[2].(clienttesting.WatchAction).GetWatchRestrictions().ResourceVersion != "234" { t.Error(spew.Sdump(actions)) } }, @@ -945,7 +1066,7 @@ func TestWaitForCondition(t *testing.T) { }, timeout: 1 * time.Second, - expectedErr: "timed out waiting for the condition on theresource/name-foo", + expectedErr: `theresource.group "name-foo" not found`, validateActions: func(t *testing.T, actions []clienttesting.Action) { if len(actions) != 2 { t.Fatal(spew.Sdump(actions)) @@ -1022,7 +1143,7 @@ func TestWaitForCondition(t *testing.T) { }, timeout: 1 * time.Second, - expectedErr: "timed out waiting for the condition on theresource/name-foo", + expectedErr: `theresource.group "name-foo" not found`, validateActions: func(t *testing.T, actions []clienttesting.Action) { if len(actions) != 2 { t.Fatal(spew.Sdump(actions)) @@ -1107,7 +1228,9 @@ func TestWaitForCondition(t *testing.T) { } } - test.validateActions(t, fakeClient.Actions()) + if test.validateActions != nil { + test.validateActions(t, fakeClient.Actions()) + } }) } } @@ -1305,7 +1428,7 @@ func TestWaitForDifferentJSONPathExpression(t *testing.T) { o := &WaitOptions{ ResourceFinder: genericclioptions.NewSimpleFakeResourceFinder(infos...), DynamicClient: fakeClient, - Timeout: 1 * time.Millisecond, + Timeout: 1 * time.Second, Printer: printers.NewDiscardingPrinter(), ConditionFn: JSONPathWait{ @@ -1376,10 +1499,12 @@ func TestWaitForJSONPathCondition(t *testing.T) { expectedErr: None, validateActions: func(t *testing.T, actions []clienttesting.Action) { - if len(actions) != 1 { + if len(actions) != 2 { t.Fatal(spew.Sdump(actions)) } - if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=foo-b6699dcfb-rnv7t" { + if !actions[0].Matches("list", "theresource") || + actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=foo-b6699dcfb-rnv7t" && + actions[1].(clienttesting.WatchAction).GetWatchRestrictions().Fields.String() != "metadata.name=foo-b6699dcfb-rnv7t" { t.Error(spew.Sdump(actions)) } }, @@ -1441,7 +1566,7 @@ func TestWaitForJSONPathCondition(t *testing.T) { }, timeout: 1 * time.Second, - expectedErr: "timed out waiting for the condition on theresource/foo-b6699dcfb-rnv7t", + expectedErr: `theresource.group "foo-b6699dcfb-rnv7t" not found`, validateActions: func(t *testing.T, actions []clienttesting.Action) { if len(actions) != 2 { t.Fatal(spew.Sdump(actions)) @@ -1480,7 +1605,7 @@ func TestWaitForJSONPathCondition(t *testing.T) { count++ fakeWatch := watch.NewRaceFreeFake() go func() { - time.Sleep(100 * time.Millisecond) + time.Sleep(1 * time.Second) fakeWatch.Stop() }() return true, fakeWatch, nil @@ -1496,7 +1621,7 @@ func TestWaitForJSONPathCondition(t *testing.T) { expectedErr: "timed out waiting for the condition on theresource/foo-b6699dcfb-rnv7t", validateActions: func(t *testing.T, actions []clienttesting.Action) { - if len(actions) != 4 { + if len(actions) != 3 { t.Fatal(spew.Sdump(actions)) } if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=foo-b6699dcfb-rnv7t" { @@ -1505,10 +1630,7 @@ func TestWaitForJSONPathCondition(t *testing.T) { if !actions[1].Matches("watch", "theresource") || actions[1].(clienttesting.WatchAction).GetWatchRestrictions().ResourceVersion != "234" { t.Error(spew.Sdump(actions)) } - if !actions[2].Matches("list", "theresource") || actions[2].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=foo-b6699dcfb-rnv7t" { - t.Error(spew.Sdump(actions)) - } - if !actions[3].Matches("watch", "theresource") || actions[3].(clienttesting.WatchAction).GetWatchRestrictions().ResourceVersion != "234" { + if !actions[2].Matches("watch", "theresource") || actions[2].(clienttesting.WatchAction).GetWatchRestrictions().ResourceVersion != "234" { t.Error(spew.Sdump(actions)) } }, @@ -1606,7 +1728,7 @@ func TestWaitForJSONPathCondition(t *testing.T) { fakeClient: func() *dynamicfakeclient.FakeDynamicClient { fakeClient := dynamicfakeclient.NewSimpleDynamicClientWithCustomListKinds(scheme, listMapping) fakeClient.PrependReactor("list", "theresource", func(action clienttesting.Action) (handled bool, ret runtime.Object, err error) { - return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "ns-foo", "name-foo")), nil + return true, newUnstructuredList(newUnstructured("group/version", "TheKind", "default", "foo-b6699dcfb-rnv7t")), nil }) count := 0 fakeClient.PrependWatchReactor("theresource", func(action clienttesting.Action) (handled bool, ret watch.Interface, err error) { @@ -1633,20 +1755,14 @@ func TestWaitForJSONPathCondition(t *testing.T) { expectedErr: None, validateActions: func(t *testing.T, actions []clienttesting.Action) { - if len(actions) != 4 { + if len(actions) != 2 { t.Fatal(spew.Sdump(actions)) } if !actions[0].Matches("list", "theresource") || actions[0].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=foo-b6699dcfb-rnv7t" { - t.Error(spew.Sdump(actions)) + t.Error(spew.Sdump(actions[0])) } - if !actions[1].Matches("watch", "theresource") { - t.Error(spew.Sdump(actions)) - } - if !actions[2].Matches("list", "theresource") || actions[2].(clienttesting.ListAction).GetListRestrictions().Fields.String() != "metadata.name=foo-b6699dcfb-rnv7t" { - t.Error(spew.Sdump(actions)) - } - if !actions[3].Matches("watch", "theresource") { - t.Error(spew.Sdump(actions)) + if !actions[1].Matches("watch", "theresource") || actions[1].(clienttesting.WatchAction).GetWatchRestrictions().Fields.String() != "metadata.name=foo-b6699dcfb-rnv7t" { + t.Error(spew.Sdump(actions[1])) } }, },