Output openTSDB HTTPS with basic auth (#1913)

influxdata · Dec 13, 2016 · a611489 · a611489
1 parent 9add7b9
commit a611489
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/plugins/outputs/opentsdb/opentsdb.go b/plugins/outputs/opentsdb/opentsdb.go
@@ -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,
 	}

diff --git a/plugins/outputs/opentsdb/opentsdb_http.go b/plugins/outputs/opentsdb/opentsdb_http.go
@@ -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",
 	}