diff options
| author | Christian Pointner <equinox@spreadspace.org> | 2015-10-20 02:05:29 +0200 |
|---|---|---|
| committer | Christian Pointner <equinox@spreadspace.org> | 2015-10-20 02:05:29 +0200 |
| commit | d1f90f25d8252d7203f7246ed0cf0200ace3b259 (patch) | |
| tree | 9bb2cf5cf4ccd1d360797accba2d2af0e81c2bac | |
| parent | bugfix for grahpite forwarding (diff) | |
using new factory method for graphite
| -rw-r--r-- | src/hub/src/spreadspace.org/sfive/s5srvForwardGraphite.go | 4 |
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) |