diff --git a/kubernetes/adapter.go b/kubernetes/adapter.go index d85eb1c6..615cff15 100644 --- a/kubernetes/adapter.go +++ b/kubernetes/adapter.go @@ -395,7 +395,7 @@ func (a *Adapter) UpdateIngressLoadBalancer(ingress *Ingress, loadBalancerDNSNam case TypeIngress: return a.ingressClient.updateIngressLoadBalancer(a.kubeClient, ingress.Namespace, ingress.Name, loadBalancerDNSName) } - return fmt.Errorf("unknown resourceType '%s', failed to update kubernetes resource", ingress.ResourceType) + return fmt.Errorf("unknown resourceType '%s', failed to update Kubernetes resource", ingress.ResourceType) } // GetConfigMap retrieves the ConfigMap with name from namespace. diff --git a/kubernetes/config.go b/kubernetes/config.go index 105f9185..9f37e899 100644 --- a/kubernetes/config.go +++ b/kubernetes/config.go @@ -1,6 +1,7 @@ package kubernetes import ( + "fmt" "net" "os" "time" @@ -70,7 +71,11 @@ func InClusterConfig() (*Config, error) { dir := serviceAccountLocator() tokenProvider := secrets.NewSecretPaths(time.Minute) - tokenProvider.Add(dir + serviceAccountTokenKey) + err := tokenProvider.Add(dir + serviceAccountTokenKey) + + if err != nil { + return nil, fmt.Errorf("error when adding token file to token provider: %v", err) + } rootCAFile := dir + serviceAccountRootCAKey if _, err := os.Stat(rootCAFile); os.IsNotExist(err) {