fix(discovery): add retries to discover kubernetes api (#174)

Signed-off-by: AmitKumarDas <[email protected]>

Author: Amit Kumar Das

pkg/kubernetes/utility.go

@@ -173,6 +173,16 @@ func (u *Utility) setAPIResourceDiscoveryOrDefault(config UtilityConfig) {
 	// this interval for these new CRDs to be discovered.
 	d.Start(time.Duration(30) * time.Second)
 
+	// loop for a while till resources are discovered
+	var count int
+	for {
+		if d.HasSynced() || count >= 5 {
+			break
+		}
+		time.Sleep(1 * time.Second)
+		count++
+	}
+
 	u.apiResourceDiscovery = d
 }
 

pkg/recipe/list.go

@@ -19,6 +19,7 @@ package recipe
 import (
 	"fmt"
 
+	"github.com/pkg/errors"
 	"k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
@@ -53,14 +54,20 @@ func (l *Listable) listCRDs() (*types.ListResult, error) {
 	var crd *v1beta1.CustomResourceDefinition
 	err := UnstructToTyped(l.List.State, &crd)
 	if err != nil {
-		return nil, err
+		return nil, errors.Wrapf(
+			err,
+			"Failed to transform unstruct instance to crd equivalent",
+		)
 	}
 	// use crd client to list crds
 	items, err := l.crdClient.
 		CustomResourceDefinitions().
 		List(metav1.ListOptions{})
 	if err != nil {
-		return nil, err
+		return nil, errors.Wrapf(
+			err,
+			"Failed to list crds",
+		)
 	}
 	return &types.ListResult{
 		Phase: types.ListStatusPassed,
@@ -85,13 +92,19 @@ func (l *Listable) listResources() (*types.ListResult, error) {
 		l.List.State.GetKind(),
 	)
 	if err != nil {
-		return nil, err
+		return nil, errors.Wrapf(
+			err,
+			"Failed to get resource client",
+		)
 	}
 	items, err := client.
 		Namespace(l.List.State.GetNamespace()).
 		List(metav1.ListOptions{}) // TODO add label selector
 	if err != nil {
-		return nil, err
+		return nil, errors.Wrapf(
+			err,
+			"Failed to list resources",
+		)
 	}
 	return &types.ListResult{
 		Phase:   types.ListStatusPassed,