mirror of
https://github.com/grafana/grafana.git
synced 2025-02-14 01:23:32 -06:00
2c7adccf12
* datasource: move caching closer to datasource struct * tsdb: use cached version of datasource http transport closes #6825
37 lines
761 B
Go
37 lines
761 B
Go
package tsdb
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/grafana/grafana/pkg/models"
|
|
)
|
|
|
|
type Executor interface {
|
|
Execute(ctx context.Context, queries QuerySlice, query *QueryContext) *BatchResult
|
|
}
|
|
|
|
var registry map[string]GetExecutorFn
|
|
|
|
type GetExecutorFn func(dsInfo *models.DataSource) (Executor, error)
|
|
|
|
func init() {
|
|
registry = make(map[string]GetExecutorFn)
|
|
}
|
|
|
|
func getExecutorFor(dsInfo *models.DataSource) (Executor, error) {
|
|
if fn, exists := registry[dsInfo.Type]; exists {
|
|
executor, err := fn(dsInfo)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return executor, nil
|
|
}
|
|
return nil, fmt.Errorf("Could not find executor for data source type: %s", dsInfo.Type)
|
|
}
|
|
|
|
func RegisterExecutor(pluginId string, fn GetExecutorFn) {
|
|
registry[pluginId] = fn
|
|
}
|