diff options
| -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) |