From ff48ba08ac41f94692ed27a26a9ca52d84df8954 Mon Sep 17 00:00:00 2001 From: shivdudhani Date: Wed, 15 May 2019 15:08:06 -0700 Subject: [PATCH] cleanup --- client/client.go | 4 ++-- client/utils.go | 1 - pkg/controller/controller.go | 1 - pkg/event/controller.go | 6 +++--- 4 files changed, 5 insertions(+), 7 deletions(-) diff --git a/client/client.go b/client/client.go index c64d46c093..721ae55fb4 100644 --- a/client/client.go +++ b/client/client.go @@ -303,10 +303,10 @@ func (c *Client) waitUntilNamespaceIsCreated(name string) error { //GetSupportedKinds provides list of supported types func GetSupportedKinds() []string { - return rTypes + return supportedTypes } -var rTypes = []string{ +var supportedTypes = []string{ "ConfigMap", "Pods", "Deployment", "CronJob", "Endpoints", "HorizontalPodAutoscaler", "Ingress", "Job", "LimitRange", "Namespace", "NetworkPolicy", "PersistentVolumeClaim", "PodDisruptionBudget", "PodTemplate", "ResourceQuota", "Secret", "Service", "StatefulSet", diff --git a/client/utils.go b/client/utils.go index 443f2aed63..63a5f46a41 100644 --- a/client/utils.go +++ b/client/utils.go @@ -56,7 +56,6 @@ func refreshRegisteredResources(mapper map[string]schema.GroupVersionResource, c for _, apiResource := range resourceList { for _, resource := range apiResource.APIResources { - // fmt.Println(resource.Name + " : " + apiResource.APIVersion + " , " + apiResource.GroupVersion + " , " + resource.Name) grpVersion := strings.Split(apiResource.GroupVersion, "/") if len(grpVersion) == 2 { mapper[resource.Name] = schema.GroupVersionResource{ diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go index 8d63b22f03..f29659ae2c 100644 --- a/pkg/controller/controller.go +++ b/pkg/controller/controller.go @@ -85,7 +85,6 @@ func (pc *PolicyController) deletePolicyHandler(resource interface{}) { func (pc *PolicyController) enqueuePolicy(obj interface{}) { var key string var err error - pc.logger.Println("enque") if key, err = cache.MetaNamespaceKeyFunc(obj); err != nil { utilruntime.HandleError(err) return diff --git a/pkg/event/controller.go b/pkg/event/controller.go index 6994d37a5a..d291afe734 100644 --- a/pkg/event/controller.go +++ b/pkg/event/controller.go @@ -90,11 +90,11 @@ func (c *controller) Run(stopCh <-chan struct{}) { for i := 0; i < eventWorkerThreadCount; i++ { go wait.Until(c.runWorker, time.Second, stopCh) } - log.Println("Started eventbuilder controller workers") + c.logger.Println("Started eventbuilder controller workers") } func (c *controller) Stop() { - log.Println("Shutting down eventbuilder controller workers") + c.logger.Println("Shutting down eventbuilder controller workers") } func (c *controller) runWorker() { for c.processNextWorkItem() { @@ -124,7 +124,7 @@ func (c *controller) processNextWorkItem() bool { }(obj) if err != nil { - log.Println((err)) + c.logger.Println((err)) } return true }