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

fix linter errors

This commit is contained in:
ncohensm 2016-06-22 18:01:30 -07:00
parent cf08b56460
commit 2f36631f0e
2 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
plugins/inputs/http_listener/http_listener.go
View File

@ -17,9 +17,9 @@ import (
) )
type HttpListener struct { type HttpListener struct {
ServiceAddress string ServiceAddress string
ReadTimeout string ReadTimeout string
WriteTimeout string WriteTimeout string
sync.Mutex sync.Mutex
@ -89,9 +89,9 @@ func (t *HttpListener) httpListen() error {
writeTimeout, err := strconv.ParseInt(t.WriteTimeout, 10, 32) writeTimeout, err := strconv.ParseInt(t.WriteTimeout, 10, 32)
var server = http.Server{ var server = http.Server{
Handler: t, Handler: t,
ReadTimeout: time.Duration(readTimeout) * time.Second, ReadTimeout: time.Duration(readTimeout) * time.Second,
WriteTimeout: time.Duration(writeTimeout) * time.Second, WriteTimeout: time.Duration(writeTimeout) * time.Second,
} }
err = server.Serve(t.listener) err = server.Serve(t.listener)

9
plugins/inputs/http_listener/http_listener_test.go
View File

@ -7,9 +7,9 @@ import (
"github.com/influxdata/telegraf/plugins/parsers" "github.com/influxdata/telegraf/plugins/parsers"
"github.com/influxdata/telegraf/testutil" "github.com/influxdata/telegraf/testutil"
"bytes"
"github.com/stretchr/testify/require" "github.com/stretchr/testify/require"
"net/http" "net/http"
"bytes"
) )
const ( const (
@ -26,11 +26,11 @@ cpu_load_short,host=server06 value=12.0 1422568543702900257
emptyMsg = "" emptyMsg = ""
) )
func newTestHttpListener() (*HttpListener) { func newTestHttpListener() *HttpListener {
listener := &HttpListener{ listener := &HttpListener{
ServiceAddress: ":8186", ServiceAddress: ":8186",
ReadTimeout: "10", ReadTimeout: "10",
WriteTimeout: "10", WriteTimeout: "10",
} }
return listener return listener
} }
@ -125,4 +125,3 @@ func TestQueryHTTP(t *testing.T) {
require.NoError(t, err) require.NoError(t, err)
require.EqualValues(t, 200, resp.StatusCode) require.EqualValues(t, 200, resp.StatusCode)
} }