log no CRD found error

Author: interma

Gopkg.lock

@@ -20,7 +20,6 @@ required = ["sigs.k8s.io/testing_frameworks/integration",
             "github.com/go-openapi/spec",
             "k8s.io/kube-openapi/pkg/common",
             "k8s.io/apiextensions-apiserver",
-            "github.com/pkg/errors",
             ]
 
 [[constraint]]

Gopkg.toml

@@ -20,20 +20,21 @@ import (
 	"fmt"
 	"sync"
 
-	"github.com/pkg/errors"
-
 	"k8s.io/apimachinery/pkg/api/meta"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/client-go/util/workqueue"
 	"sigs.k8s.io/controller-runtime/pkg/event"
 	"sigs.k8s.io/controller-runtime/pkg/handler"
 	"sigs.k8s.io/controller-runtime/pkg/runtime/inject"
+	logf "sigs.k8s.io/controller-runtime/pkg/runtime/log"
 	"sigs.k8s.io/controller-runtime/pkg/source/internal"
 
 	"sigs.k8s.io/controller-runtime/pkg/cache"
 	"sigs.k8s.io/controller-runtime/pkg/predicate"
 )
 
+var log = logf.KBLog.WithName("source")
+
 const (
 	// defaultBufferSize is the default number of event notifications that can be buffered.
 	defaultBufferSize = 1024
@@ -65,7 +66,6 @@ type Kind struct {
 
 var _ Source = &Kind{}
 
-
 // Start is internal and should be called only by the Controller to register an EventHandler with the Informer
 // to enqueue reconcile.Requests.
 func (ks *Kind) Start(handler handler.EventHandler, queue workqueue.RateLimitingInterface,
@@ -86,11 +86,10 @@ func (ks *Kind) Start(handler handler.EventHandler, queue workqueue.RateLimiting
 	if err != nil {
 		switch err.(type) {
 		case *meta.NoKindMatchError:
-			return errors.Wrapf(err, "if %s is a CRD, should install it before calling Start",
+			log.Error(err, "if %s is a CRD, should install it before calling Start",
 				err.(*meta.NoKindMatchError).GroupKind)
-		default:
-			return err
 		}
+		return err
 	}
 	i.AddEventHandler(internal.EventHandler{Queue: queue, EventHandler: handler, Predicates: prct})
 	return nil