Merge pull request #61 from rebuy-de/ignore-statsd-errors

continue on statsd errors

pkg/api/app.go

@@ -34,11 +34,7 @@ func New(p *Parameters) (*App, error) {
 	app.Parameters = p
 
 	app.Clients = &Clients{}
-	app.Clients.Statsd, err = statsdw.New(p.StatsdAddress)
-	if err != nil {
-		return nil, errors.Wrap(err, "failed to initialize statsd client")
-	}
-
+	app.Clients.Statsd = statsdw.New(p.StatsdAddress)
 	app.Clients.GitHub = gh.New(p.GitHubToken, p.HTTPCacheDir, app.Clients.Statsd)
 	app.Clients.Kubectl = kubectl.New(p.KubectlPath, p.Kubeconfig)
 

pkg/statsdw/wrapper.go

@@ -1,16 +1,22 @@
 package statsdw
 
-import statsd "gopkg.in/alexcesaro/statsd.v2"
+import (
+	"fmt"
+
+	"github.com/pkg/errors"
+	log "github.com/sirupsen/logrus"
+	statsd "gopkg.in/alexcesaro/statsd.v2"
+)
 
 var Prefix = "kubernetes-deployment"
 
 type Wrapper struct {
 	c *statsd.Client
 }
 
-func New(addr string) (Interface, error) {
+func New(addr string) Interface {
 	if addr == "" {
-		return NullClient{}, nil
+		return NullClient{}
 	}
 
 	c, err := statsd.New(
@@ -19,10 +25,13 @@ func New(addr string) (Interface, error) {
 		statsd.TagsFormat(statsd.Datadog),
 	)
 	if err != nil {
-		return nil, err
+		log.WithFields(log.Fields{
+			"StackTrace": fmt.Sprintf("%+v", errors.WithStack(err)),
+		}).Warn("failed to initialize statsd client")
+		return NullClient{}
 	}
 
-	return &Wrapper{c}, nil
+	return &Wrapper{c}
 }
 
 func (w *Wrapper) Gauge(bucket string, value interface{}) {