dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix redis : change ending call with "\r\n"

This commit is contained in:
Loïc 2015-07-13 18:21:16 +02:00
parent c4e5e743c4
commit d5b4e4ba60
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/redis/redis.go
View File

@ -126,7 +126,7 @@ func (g *Redis) gatherServer(addr *url.URL, acc plugins.Accumulator) error {
if addr.User != nil { if addr.User != nil {
pwd, set := addr.User.Password() pwd, set := addr.User.Password()
if set && pwd != "" { if set && pwd != "" {
c.Write([]byte(fmt.Sprintf("AUTH %s\n", pwd))) c.Write([]byte(fmt.Sprintf("AUTH %s\r\n", pwd)))
r := bufio.NewReader(c) r := bufio.NewReader(c)
@ -143,7 +143,7 @@ func (g *Redis) gatherServer(addr *url.URL, acc plugins.Accumulator) error {
g.c = c g.c = c
} }
g.c.Write([]byte("info\n")) g.c.Write([]byte("info\r\n"))
r := bufio.NewReader(g.c) r := bufio.NewReader(g.c)

4
plugins/redis/redis_test.go
View File

@ -31,7 +31,7 @@ func TestRedisGeneratesMetrics(t *testing.T) {
return return
} }
if line != "info\n" { if line != "info\r\n" {
return return
} }
@ -122,7 +122,7 @@ func TestRedisCanPullStatsFromMultipleServers(t *testing.T) {
return return
} }
if line != "info\n" { if line != "info\r\n" {
return return
} }