|
@@ -7,11 +7,11 @@ import (
|
|
|
"time"
|
|
"time"
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
-func Graphite(r Registry, interval int, addr string) {
|
|
|
|
|
|
|
+func Graphite(r Registry, interval int, addr *net.TCPAddr) {
|
|
|
for {
|
|
for {
|
|
|
now := time.Now().Unix()
|
|
now := time.Now().Unix()
|
|
|
- conn, err := net.Dial("tcp", addr)
|
|
|
|
|
- if err != nil {
|
|
|
|
|
|
|
+ conn, err := net.DialTCP("tcp", nil, addr)
|
|
|
|
|
+ if nil != err {
|
|
|
continue
|
|
continue
|
|
|
}
|
|
}
|
|
|
w := bufio.NewWriter(conn)
|
|
w := bufio.NewWriter(conn)
|