mirror of https://github.com/grafana/grafana.git
61 lines
1.4 KiB
Go
61 lines
1.4 KiB
Go
package api
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/grafana/grafana/pkg/api/pluginproxy"
|
|
"github.com/grafana/grafana/pkg/bus"
|
|
"github.com/grafana/grafana/pkg/metrics"
|
|
"github.com/grafana/grafana/pkg/middleware"
|
|
m "github.com/grafana/grafana/pkg/models"
|
|
"github.com/grafana/grafana/pkg/plugins"
|
|
)
|
|
|
|
const HeaderNameNoBackendCache = "X-Grafana-NoCache"
|
|
|
|
func (hs *HttpServer) getDatasourceById(id int64, orgId int64, nocache bool) (*m.DataSource, error) {
|
|
cacheKey := fmt.Sprintf("ds-%d", id)
|
|
|
|
if !nocache {
|
|
if cached, found := hs.cache.Get(cacheKey); found {
|
|
ds := cached.(*m.DataSource)
|
|
if ds.OrgId == orgId {
|
|
return ds, nil
|
|
}
|
|
}
|
|
}
|
|
|
|
query := m.GetDataSourceByIdQuery{Id: id, OrgId: orgId}
|
|
if err := bus.Dispatch(&query); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
hs.cache.Set(cacheKey, query.Result, time.Second*5)
|
|
return query.Result, nil
|
|
}
|
|
|
|
func (hs *HttpServer) ProxyDataSourceRequest(c *middleware.Context) {
|
|
c.TimeRequest(metrics.M_DataSource_ProxyReq_Timer)
|
|
|
|
nocache := c.Req.Header.Get(HeaderNameNoBackendCache) == "true"
|
|
|
|
ds, err := hs.getDatasourceById(c.ParamsInt64(":id"), c.OrgId, nocache)
|
|
|
|
if err != nil {
|
|
c.JsonApiErr(500, "Unable to load datasource meta data", err)
|
|
return
|
|
}
|
|
|
|
// find plugin
|
|
plugin, ok := plugins.DataSources[ds.Type]
|
|
if !ok {
|
|
c.JsonApiErr(500, "Unable to find datasource plugin", err)
|
|
return
|
|
}
|
|
|
|
proxyPath := c.Params("*")
|
|
proxy := pluginproxy.NewDataSourceProxy(ds, plugin, c, proxyPath)
|
|
proxy.HandleRequest()
|
|
}
|