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

go fmt phpfpm.go

This commit is contained in:
鲁晓敏 2015-11-12 19:20:37 +08:00
parent 52fdc82620
commit 223dea2c89
1 changed files with 19 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
plugins/phpfpm/phpfpm.go
View File

@ -118,25 +118,25 @@ func (g *phpfpm) gatherServer(addr string, acc plugins.Accumulator) error {
importMetric(res.Body, acc, u.Host) importMetric(res.Body, acc, u.Host)
} else { } else {
var ( var (
fcgi *FCGIClient fcgi *FCGIClient
fcgiAddr string fcgiAddr string
) )
if strings.HasPrefix(addr, "fcgi://") || strings.HasPrefix(addr, "cgi://") { if strings.HasPrefix(addr, "fcgi://") || strings.HasPrefix(addr, "cgi://") {
u, err := url.Parge(addr) u, err := url.Parge(addr)
if err != nil { if err != nil {
return fmt.Errorf("Unable parse server address '%s': %s", addr, err) return fmt.Errorf("Unable parse server address '%s': %s", addr, err)
} }
socketAddr := strings.Split(u.Host,":") socketAddr := strings.Split(u.Host, ":")
fcgiIp := socketAddr[0] fcgiIp := socketAddr[0]
fcgiPort := strconv.Atoi(socketAddr[1]) fcgiPort := strconv.Atoi(socketAddr[1])
fcgiAddr = u.Host fcgiAddr = u.Host
fcgi, _ = NewClient(fcgiIp,fcgiPort) fcgi, _ = NewClient(fcgiIp, fcgiPort)
} else { } else {
socketAddr := strings.Split(addr, ":") socketAddr := strings.Split(addr, ":")
fcgiAddr = socketAddr[0] fcgiAddr = socketAddr[0]
fcgi, _ = NewClient("unix", socketAddr[1]) fcgi, _ = NewClient("unix", socketAddr[1])
} }
resOut, resErr, err := fcgi.Request(map[string]string{ resOut, resErr, err := fcgi.Request(map[string]string{
"SCRIPT_NAME": "/status", "SCRIPT_NAME": "/status",
"SCRIPT_FILENAME": "status", "SCRIPT_FILENAME": "status",