Procházet zdrojové kódy

feat(mqe): init commit

bergquist před 9 roky
rodič
revize
bd3259d07a
3 změnil soubory, kde provedl 35 přidání a 0 odebrání
  1. 1 0
      pkg/cmd/grafana-server/main.go
  2. 33 0
      pkg/tsdb/mqe/mqe.go
  3. 1 0
      pkg/tsdb/mqe/types.go

+ 1 - 0
pkg/cmd/grafana-server/main.go

@@ -21,6 +21,7 @@ import (
 	_ "github.com/grafana/grafana/pkg/services/alerting/notifiers"
 	_ "github.com/grafana/grafana/pkg/tsdb/graphite"
 	_ "github.com/grafana/grafana/pkg/tsdb/influxdb"
+	_ "github.com/grafana/grafana/pkg/tsdb/mqe"
 	_ "github.com/grafana/grafana/pkg/tsdb/opentsdb"
 	_ "github.com/grafana/grafana/pkg/tsdb/prometheus"
 	_ "github.com/grafana/grafana/pkg/tsdb/testdata"

+ 33 - 0
pkg/tsdb/mqe/mqe.go

@@ -0,0 +1,33 @@
+package mqe
+
+import (
+	"context"
+	"net/http"
+
+	"github.com/grafana/grafana/pkg/log"
+	"github.com/grafana/grafana/pkg/tsdb"
+)
+
+type MQEExecutor struct {
+	*tsdb.DataSourceInfo
+}
+
+func NewMQEExecutor(dsInfo *tsdb.DataSourceInfo) tsdb.Executor {
+	return &MQEExecutor{dsInfo}
+}
+
+var (
+	glog       log.Logger
+	HttpClient *http.Client
+)
+
+func init() {
+	glog = log.New("tsdb.mqe")
+	tsdb.RegisterExecutor("mqe", NewMQEExecutor)
+
+	HttpClient = tsdb.GetDefaultClient()
+}
+
+func (e *MQEExecutor) Execute(ctx context.Context, queries tsdb.QuerySlice, context *tsdb.QueryContext) *tsdb.BatchResult {
+	return &tsdb.BatchResult{}
+}

+ 1 - 0
pkg/tsdb/mqe/types.go

@@ -0,0 +1 @@
+package mqe