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

Output openTSDB HTTPS with basic auth (#1913)

This commit is contained in:
Anthony Arnaud 2016-12-13 09:15:51 -05:00 committed by Cameron Sparr
parent 6e241611be
commit 7558081873
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/outputs/opentsdb/opentsdb.go
View File

@ -90,7 +90,7 @@ func (o *OpenTSDB) Write(metrics []telegraf.Metric) error {
if u.Scheme == "" || u.Scheme == "tcp" {
return o.WriteTelnet(metrics, u)
} else if u.Scheme == "http" {
} else if u.Scheme == "http" || u.Scheme == "https" {
return o.WriteHttp(metrics, u)
} else {
return fmt.Errorf("Unknown scheme in host parameter.")
@ -101,6 +101,8 @@ func (o *OpenTSDB) WriteHttp(metrics []telegraf.Metric, u *url.URL) error {
http := openTSDBHttp{
Host: u.Host,
Port: o.Port,
Scheme: u.Scheme,
User: u.User,
BatchSize: o.HttpBatchSize,
Debug: o.Debug,
}

5
plugins/outputs/opentsdb/opentsdb_http.go
View File

@ -23,6 +23,8 @@ type HttpMetric struct {
type openTSDBHttp struct {
Host string
Port int
Scheme string
User *url.Userinfo
BatchSize int
Debug bool
@ -118,7 +120,8 @@ func (o *openTSDBHttp) flush() error {
o.body.close()
u := url.URL{
Scheme: "http",
Scheme: o.Scheme,
User: o.User,
Host: fmt.Sprintf("%s:%d", o.Host, o.Port),
Path: "/api/put",
}