summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristian Pointner <equinox@spreadspace.org>2015-10-20 02:05:29 +0200
committerChristian Pointner <equinox@spreadspace.org>2015-10-20 02:05:29 +0200
commitd1f90f25d8252d7203f7246ed0cf0200ace3b259 (patch)
tree9bb2cf5cf4ccd1d360797accba2d2af0e81c2bac
parentbugfix for grahpite forwarding (diff)
using new factory method for graphite
-rw-r--r--src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go4
1 files changed, 1 insertions, 3 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go b/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go
index e24142c..802be3c 100644
--- a/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go
+++ b/src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go
@@ -18,11 +18,9 @@ func (self StatsSinkServer) getLastUpdateGraphite(conn *graphite.Graphite) (late
}
func (self StatsSinkServer) handleForwardingToGraphite(forwardHost string, basePath string) {
- client := &graphite.Graphite{Address: forwardHost}
-
tryResync:
for {
- err := client.Connect()
+ client, err := graphite.NewGraphiteFromAddress(forwardHost);
if err != nil {
s5l.Printf("fwd-graphite: connect returned err: %v", err)
time.Sleep(5 * time.Second)