From 2ee78bf9d3c4486301e7ad3ac905e2c5e5f5e680 Mon Sep 17 00:00:00 2001 From: lburgazzoli Date: Wed, 6 Mar 2019 21:30:54 +0100 Subject: [PATCH] chore(lint): fix findings --- pkg/trait/gc.go | 1 - pkg/trait/knative_service.go | 4 +--- pkg/trait/knative_service_env.go | 10 ++++++++-- pkg/trait/knative_service_vol.go | 4 +--- pkg/util/kubernetes/resolver.go | 1 + 5 files changed, 11 insertions(+), 9 deletions(-) diff --git a/pkg/trait/gc.go b/pkg/trait/gc.go index ce761db6db..191155b5c5 100644 --- a/pkg/trait/gc.go +++ b/pkg/trait/gc.go @@ -22,7 +22,6 @@ import ( "fmt" "strconv" - k8serrors "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" diff --git a/pkg/trait/knative_service.go b/pkg/trait/knative_service.go index b8df0912db..afa9eea7a9 100644 --- a/pkg/trait/knative_service.go +++ b/pkg/trait/knative_service.go @@ -202,9 +202,7 @@ func (t *knativeServiceTrait) getServiceFor(e *Environment) (*serving.Service, e envvar.SetVal(environment, "AB_JOLOKIA_OFF", True) if t.ConfigurationType == "volume" { - if err := t.bindToVolumes(e, &svc); err != nil { - return nil, err - } + t.bindToVolumes(e, &svc) } else { if err := t.bindToEnvVar(e, &svc); err != nil { return nil, err diff --git a/pkg/trait/knative_service_env.go b/pkg/trait/knative_service_env.go index 04a181f0a2..e4817067a5 100644 --- a/pkg/trait/knative_service_env.go +++ b/pkg/trait/knative_service_env.go @@ -49,9 +49,12 @@ func (t *knativeServiceTrait) bindToEnvVar(e *Environment, service *serving.Serv t.L.Errorf(err, "failed to lookup ConfigMap %s", cmName) } if cm != nil { - util.ExtractApplicationProperties(cm.Data, func(key string, val string) { + err = util.ExtractApplicationProperties(cm.Data, func(key string, val string) { properties[key] = val }) + if err != nil { + t.L.Errorf(err, "failed to extract properties from ConfigMap %s", cmName) + } } }) @@ -61,9 +64,12 @@ func (t *knativeServiceTrait) bindToEnvVar(e *Environment, service *serving.Serv t.L.Errorf(err, "failed to lookup Secret %s", secretName) } if cm != nil { - util.ExtractEncodedApplicationProperties(cm.Data, func(key string, val string) { + err = util.ExtractEncodedApplicationProperties(cm.Data, func(key string, val string) { properties[key] = val }) + if err != nil { + t.L.Errorf(err, "failed to extract properties from Secret %s", secretName) + } } }) diff --git a/pkg/trait/knative_service_vol.go b/pkg/trait/knative_service_vol.go index 9bf1ee7340..efe058dc4e 100644 --- a/pkg/trait/knative_service_vol.go +++ b/pkg/trait/knative_service_vol.go @@ -24,7 +24,7 @@ import ( serving "github.com/knative/serving/pkg/apis/serving/v1alpha1" ) -func (t *knativeServiceTrait) bindToVolumes(e *Environment, service *serving.Service) error { +func (t *knativeServiceTrait) bindToVolumes(e *Environment, service *serving.Service) { e.ConfigureVolumesAndMounts( t.deployer.ContainerImage, &service.Spec.RunLatest.Configuration.RevisionTemplate.Spec.Volumes, @@ -38,6 +38,4 @@ func (t *knativeServiceTrait) bindToVolumes(e *Environment, service *serving.Ser envvar.SetVal(environment, "CAMEL_K_ROUTES", strings.Join(paths, ",")) envvar.SetVal(environment, "CAMEL_K_CONF", "/etc/camel/conf/application.properties") envvar.SetVal(environment, "CAMEL_K_CONF_D", "/etc/camel/conf.d") - - return nil } diff --git a/pkg/util/kubernetes/resolver.go b/pkg/util/kubernetes/resolver.go index 5330e58dc7..d2ad8fc9b8 100644 --- a/pkg/util/kubernetes/resolver.go +++ b/pkg/util/kubernetes/resolver.go @@ -99,6 +99,7 @@ func ResolveIntegrationSources(context context.Context, client client.Client, in } // ResolveIntegrationResources -- +// nolint: lll func ResolveIntegrationResources(context context.Context, client client.Client, integration *v1alpha1.Integration, resources *Collection) ([]v1alpha1.ResourceSpec, error) { if integration == nil { return nil, nil