mirror of
https://github.com/grafana/grafana.git
synced 2024-11-29 20:24:18 -06:00
25 lines
498 B
Go
25 lines
498 B
Go
package tsdb
|
|
|
|
type Executor interface {
|
|
Execute(queries QuerySlice, context *QueryContext) *BatchResult
|
|
}
|
|
|
|
var registry map[string]GetExecutorFn
|
|
|
|
type GetExecutorFn func(dsInfo *DataSourceInfo) Executor
|
|
|
|
func init() {
|
|
registry = make(map[string]GetExecutorFn)
|
|
}
|
|
|
|
func getExecutorFor(dsInfo *DataSourceInfo) Executor {
|
|
if fn, exists := registry[dsInfo.PluginId]; exists {
|
|
return fn(dsInfo)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func RegisterExecutor(pluginId string, fn GetExecutorFn) {
|
|
registry[pluginId] = fn
|
|
}
|