mirror of
https://github.com/grafana/grafana.git
synced 2025-02-16 18:34:52 -06:00
c0f3b2929c
Refactor to allow shared contract between core and external backend plugins allowing core backend data sources in Grafana to be implemented in same way as an external backend plugin. Use v0.67.0 of sdk. Add tests for verifying plugin is restarted when process is killed. Enable strict linting for backendplugin packages
67 lines
1.9 KiB
Go
67 lines
1.9 KiB
Go
package plugins
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"path"
|
|
|
|
pluginModel "github.com/grafana/grafana-plugin-model/go/renderer"
|
|
"github.com/grafana/grafana/pkg/infra/log"
|
|
"github.com/grafana/grafana/pkg/plugins/backendplugin"
|
|
"github.com/grafana/grafana/pkg/plugins/backendplugin/grpcplugin"
|
|
"github.com/grafana/grafana/pkg/plugins/backendplugin/pluginextensionv2"
|
|
"github.com/grafana/grafana/pkg/util/errutil"
|
|
)
|
|
|
|
type RendererPlugin struct {
|
|
FrontendPluginBase
|
|
|
|
Executable string `json:"executable,omitempty"`
|
|
GrpcPluginV1 pluginModel.RendererPlugin
|
|
GrpcPluginV2 pluginextensionv2.RendererPlugin
|
|
backendPluginManager backendplugin.Manager
|
|
}
|
|
|
|
func (r *RendererPlugin) Load(decoder *json.Decoder, pluginDir string, backendPluginManager backendplugin.Manager) error {
|
|
if err := decoder.Decode(r); err != nil {
|
|
return err
|
|
}
|
|
|
|
if err := r.registerPlugin(pluginDir); err != nil {
|
|
return err
|
|
}
|
|
|
|
r.backendPluginManager = backendPluginManager
|
|
|
|
cmd := ComposePluginStartCommand("plugin_start")
|
|
fullpath := path.Join(r.PluginDir, cmd)
|
|
factory := grpcplugin.NewRendererPlugin(r.Id, fullpath, grpcplugin.PluginStartFuncs{
|
|
OnLegacyStart: r.onLegacyPluginStart,
|
|
OnStart: r.onPluginStart,
|
|
})
|
|
if err := backendPluginManager.Register(r.Id, factory); err != nil {
|
|
return errutil.Wrapf(err, "Failed to register backend plugin")
|
|
}
|
|
|
|
Renderer = r
|
|
return nil
|
|
}
|
|
|
|
func (r *RendererPlugin) Start(ctx context.Context) error {
|
|
if err := r.backendPluginManager.StartPlugin(ctx, r.Id); err != nil {
|
|
return errutil.Wrapf(err, "Failed to start renderer plugin")
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (r *RendererPlugin) onLegacyPluginStart(pluginID string, client *grpcplugin.LegacyClient, logger log.Logger) error {
|
|
r.GrpcPluginV1 = client.RendererPlugin
|
|
return nil
|
|
}
|
|
|
|
func (r *RendererPlugin) onPluginStart(pluginID string, client *grpcplugin.Client, logger log.Logger) error {
|
|
r.GrpcPluginV2 = client.RendererPlugin
|
|
return nil
|
|
}
|