providers

Documentation

Index

• type PluginManager
  • func NewPluginManager(logger log.Logger, cfg plugins.Config) *PluginManager
  • func (pl *PluginManager) DispenseClients(pluginClients map[string]*plugin.Client) (map[string]plugins.ProviderV1beta1, error)
  • func (pl *PluginManager) InitClients() map[string]*plugin.Client
  • func (pl *PluginManager) InitConfigs(ctx context.Context, providerPlugins map[string]plugins.ProviderV1beta1, ...) error
  • func (pl *PluginManager) Stop()
• type UnimplementedService
  • func (s *UnimplementedService) SetConfig(ctx context.Context, configRaw string) error
  • func (s *UnimplementedService) SyncRuntimeConfig(ctx context.Context, namespaceID uint64, namespaceURN string, ...) error
  • func (s *UnimplementedService) TransformToAlerts(ctx context.Context, providerID uint64, namespaceID uint64, ...) ([]alert.Alert, int, error)
  • func (s *UnimplementedService) UpsertRule(ctx context.Context, ns namespace.Namespace, prov provider.Provider, ...) error

Types

type PluginManager

type PluginManager struct {
	// contains filtered or unexported fields
}

func NewPluginManager

func NewPluginManager(logger log.Logger, cfg plugins.Config) *PluginManager

func (*PluginManager) DispenseClients

func (pl *PluginManager) DispenseClients(pluginClients map[string]*plugin.Client) (map[string]plugins.ProviderV1beta1, error)

func (*PluginManager) InitClients

func (pl *PluginManager) InitClients() map[string]*plugin.Client

func (*PluginManager) InitConfigs

func (pl *PluginManager) InitConfigs(ctx context.Context, providerPlugins map[string]plugins.ProviderV1beta1, logLevel string) error

func (*PluginManager) Stop

func (pl *PluginManager) Stop()

type UnimplementedService

type UnimplementedService struct{}

UnimplementedService is a base receiver provider service layer

func (*UnimplementedService) SetConfig

func (s *UnimplementedService) SetConfig(ctx context.Context, configRaw string) error

func (*UnimplementedService) SyncRuntimeConfig

func (s *UnimplementedService) SyncRuntimeConfig(ctx context.Context, namespaceID uint64, namespaceURN string, prov provider.Provider) error

func (*UnimplementedService) TransformToAlerts

func (s *UnimplementedService) TransformToAlerts(ctx context.Context, providerID uint64, namespaceID uint64, body map[string]any) ([]alert.Alert, int, error)

func (*UnimplementedService) UpsertRule

func (s *UnimplementedService) UpsertRule(ctx context.Context, ns namespace.Namespace, prov provider.Provider, rl *rule.Rule, templateToUpdate *template.Template) error