|
|
@@ -0,0 +1,42 @@
|
|
|
+package influxdb
|
|
|
+
|
|
|
+import (
|
|
|
+ "context"
|
|
|
+ "crypto/tls"
|
|
|
+ "net/http"
|
|
|
+ "time"
|
|
|
+
|
|
|
+ "github.com/grafana/grafana/pkg/log"
|
|
|
+ "github.com/grafana/grafana/pkg/tsdb"
|
|
|
+)
|
|
|
+
|
|
|
+type InfluxDBExecutor struct {
|
|
|
+ *tsdb.DataSourceInfo
|
|
|
+}
|
|
|
+
|
|
|
+func NewInfluxDBExecutor(dsInfo *tsdb.DataSourceInfo) tsdb.Executor {
|
|
|
+ return &InfluxDBExecutor{dsInfo}
|
|
|
+}
|
|
|
+
|
|
|
+var (
|
|
|
+ glog log.Logger
|
|
|
+ HttpClient *http.Client
|
|
|
+)
|
|
|
+
|
|
|
+func init() {
|
|
|
+ glog = log.New("tsdb.influxdb")
|
|
|
+ tsdb.RegisterExecutor("influxdb", NewInfluxDBExecutor)
|
|
|
+
|
|
|
+ tr := &http.Transport{
|
|
|
+ TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
|
|
|
+ }
|
|
|
+
|
|
|
+ HttpClient = &http.Client{
|
|
|
+ Timeout: time.Duration(15 * time.Second),
|
|
|
+ Transport: tr,
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func (e *InfluxDBExecutor) Execute(ctx context.Context, queries tsdb.QuerySlice, context *tsdb.QueryContext) *tsdb.BatchResult {
|
|
|
+ panic("missing implementation")
|
|
|
+}
|