opensource/grafana
1
0
Fork 0
mirror of https://github.com/grafana/grafana.git synced 2025-07-31 10:42:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(plugins): made plugins that live outside public work

Browse Source
This commit is contained in:
Torkel Ödegaard
2015-11-19 16:50:17 +01:00
parent f6772bb896
commit 65a7fa320a
6 changed files with 54 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
pkg/plugins/plugins.go
View File

@ -6,6 +6,7 @@ import (
"os"
"path"
"path/filepath"
"strings"
"github.com/grafana/grafana/pkg/log"
"github.com/grafana/grafana/pkg/setting"
@ -14,6 +15,7 @@ import (
var (
DataSources map[string]DataSourcePlugin
ExternalPlugins []ExternalPlugin
StaticRoutes []*StaticRootConfig
)
type PluginScanner struct {
@ -21,12 +23,27 @@ type PluginScanner struct {
errors []error
}
func Init() {
func Init() error {
DataSources = make(map[string]DataSourcePlugin)
ExternalPlugins = make([]ExternalPlugin, 0)
StaticRoutes = make([]*StaticRootConfig, 0)
scan(path.Join(setting.StaticRootPath, "app/plugins"))
scan(path.Join(setting.DataPath, "plugins"))
checkExternalPluginPaths()
return nil
}
func checkExternalPluginPaths() error {
for _, section := range setting.Cfg.Sections() {
if strings.HasPrefix(section.Name(), "plugin.") {
path := section.Key("path").String()
if path != "" {
log.Info("Plugin: scaning specific dir %s", path)
scan(path)
}
}
}
return nil
}
func scan(pluginDir string) error {
@ -45,7 +62,7 @@ func scan(pluginDir string) error {
return nil
}
func (scanner *PluginScanner) walker(path string, f os.FileInfo, err error) error {
func (scanner *PluginScanner) walker(currentPath string, f os.FileInfo, err error) error {
if err != nil {
return err
}
@ -55,17 +72,18 @@ func (scanner *PluginScanner) walker(path string, f os.FileInfo, err error) erro
}
if f.Name() == "plugin.json" {
err := scanner.loadPluginJson(path)
err := scanner.loadPluginJson(currentPath)
if err != nil {
log.Error(3, "Failed to load plugin json file: %v, err: %v", path, err)
log.Error(3, "Failed to load plugin json file: %v, err: %v", currentPath, err)
scanner.errors = append(scanner.errors, err)
}
}
return nil
}
func (scanner *PluginScanner) loadPluginJson(path string) error {
reader, err := os.Open(path)
func (scanner *PluginScanner) loadPluginJson(pluginJsonFilePath string) error {
currentDir := filepath.Dir(pluginJsonFilePath)
reader, err := os.Open(pluginJsonFilePath)
if err != nil {
return err
}
@ -96,6 +114,11 @@ func (scanner *PluginScanner) loadPluginJson(path string) error {
}
DataSources[p.Type] = p
if p.StaticRootConfig != nil {
p.StaticRootConfig.Path = path.Join(currentDir, p.StaticRootConfig.Path)
StaticRoutes = append(StaticRoutes, p.StaticRootConfig)
}
}
if pluginType == "externalPlugin" {