Documentation
¶
Index ¶
- type InfraLogWrapper
- func (l *InfraLogWrapper) Debug(args ...interface{})
- func (l *InfraLogWrapper) Debugf(format string, args ...interface{})
- func (l *InfraLogWrapper) Error(args ...interface{})
- func (l *InfraLogWrapper) Errorf(format string, args ...interface{})
- func (l *InfraLogWrapper) Failuref(format string, args ...interface{})
- func (l *InfraLogWrapper) Info(args ...interface{})
- func (l *InfraLogWrapper) Infof(format string, args ...interface{})
- func (l *InfraLogWrapper) Successf(format string, args ...interface{})
- func (l *InfraLogWrapper) Warn(args ...interface{})
- func (l *InfraLogWrapper) Warnf(format string, args ...interface{})
- type PluginManager
- func (m *PluginManager) Add(ctx context.Context, pluginID, version string) error
- func (m *PluginManager) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
- func (m *PluginManager) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
- func (m *PluginManager) CollectMetrics(ctx context.Context, req *backend.CollectMetricsRequest) (*backend.CollectMetricsResult, error)
- func (m *PluginManager) GetPluginDashboardFileContents(ctx context.Context, args *plugins.GetPluginDashboardFileContentsArgs) (*plugins.GetPluginDashboardFileContentsResult, error)
- func (m *PluginManager) Init() error
- func (m *PluginManager) ListPluginDashboardFiles(ctx context.Context, args *plugins.ListPluginDashboardFilesArgs) (*plugins.ListPluginDashboardFilesResult, error)
- func (m *PluginManager) Plugin(_ context.Context, pluginID string) (plugins.PluginDTO, bool)
- func (m *PluginManager) Plugins(_ context.Context, pluginTypes ...plugins.Type) []plugins.PluginDTO
- func (m *PluginManager) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
- func (m *PluginManager) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
- func (m *PluginManager) Remove(ctx context.Context, pluginID string) error
- func (m *PluginManager) Renderer() *plugins.Plugin
- func (m *PluginManager) Routes() []*plugins.StaticRoute
- func (m *PluginManager) Run(ctx context.Context) error
- func (m *PluginManager) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
- func (m *PluginManager) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
- type PluginSource
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InfraLogWrapper ¶
type InfraLogWrapper struct {
// contains filtered or unexported fields
}
func (*InfraLogWrapper) Debug ¶
func (l *InfraLogWrapper) Debug(args ...interface{})
func (*InfraLogWrapper) Debugf ¶
func (l *InfraLogWrapper) Debugf(format string, args ...interface{})
func (*InfraLogWrapper) Error ¶
func (l *InfraLogWrapper) Error(args ...interface{})
func (*InfraLogWrapper) Errorf ¶
func (l *InfraLogWrapper) Errorf(format string, args ...interface{})
func (*InfraLogWrapper) Failuref ¶
func (l *InfraLogWrapper) Failuref(format string, args ...interface{})
func (*InfraLogWrapper) Info ¶
func (l *InfraLogWrapper) Info(args ...interface{})
func (*InfraLogWrapper) Infof ¶
func (l *InfraLogWrapper) Infof(format string, args ...interface{})
func (*InfraLogWrapper) Successf ¶
func (l *InfraLogWrapper) Successf(format string, args ...interface{})
func (*InfraLogWrapper) Warn ¶
func (l *InfraLogWrapper) Warn(args ...interface{})
func (*InfraLogWrapper) Warnf ¶
func (l *InfraLogWrapper) Warnf(format string, args ...interface{})
type PluginManager ¶
type PluginManager struct {
// contains filtered or unexported fields
}
func New ¶
func New(cfg *plugins.Cfg, pluginSources []PluginSource, pluginLoader plugins.Loader) *PluginManager
func ProvideService ¶
func (*PluginManager) Add ¶
func (m *PluginManager) Add(ctx context.Context, pluginID, version string) error
func (*PluginManager) CallResource ¶
func (m *PluginManager) CallResource(ctx context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error
func (*PluginManager) CheckHealth ¶
func (m *PluginManager) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
func (*PluginManager) CollectMetrics ¶
func (m *PluginManager) CollectMetrics(ctx context.Context, req *backend.CollectMetricsRequest) (*backend.CollectMetricsResult, error)
func (*PluginManager) GetPluginDashboardFileContents ¶
func (m *PluginManager) GetPluginDashboardFileContents(ctx context.Context, args *plugins.GetPluginDashboardFileContentsArgs) (*plugins.GetPluginDashboardFileContentsResult, error)
func (*PluginManager) Init ¶
func (m *PluginManager) Init() error
func (*PluginManager) ListPluginDashboardFiles ¶
func (m *PluginManager) ListPluginDashboardFiles(ctx context.Context, args *plugins.ListPluginDashboardFilesArgs) (*plugins.ListPluginDashboardFilesResult, error)
func (*PluginManager) PublishStream ¶
func (m *PluginManager) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
func (*PluginManager) QueryData ¶
func (m *PluginManager) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
func (*PluginManager) Remove ¶
func (m *PluginManager) Remove(ctx context.Context, pluginID string) error
func (*PluginManager) Renderer ¶
func (m *PluginManager) Renderer() *plugins.Plugin
func (*PluginManager) Routes ¶
func (m *PluginManager) Routes() []*plugins.StaticRoute
func (*PluginManager) RunStream ¶
func (m *PluginManager) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error
func (*PluginManager) SubscribeStream ¶
func (m *PluginManager) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
type PluginSource ¶
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.