rules

package
v1.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 2, 2020 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ManagerExistsError    = ManagerStoreError("The manager already exists")
	ManagerNotExistsError = ManagerStoreError("The manager does not exist")
)

Variables

This section is empty.

Functions

This section is empty.

Types

type LocalRuleManager 

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

func NewLocalRuleManager 

func NewLocalRuleManager(storagePath string, promRuleManagers RuleManagers) *LocalRuleManager

func (*LocalRuleManager) AlertingRules 

func (l *LocalRuleManager) AlertingRules() []*rules.AlertingRule

func (*LocalRuleManager) Alertmanagers 

func (l *LocalRuleManager) Alertmanagers() []*url.URL

func (*LocalRuleManager) CreateManager 

func (l *LocalRuleManager) CreateManager(managerId, alertmanagerAddr string) error

func (*LocalRuleManager) DeleteManager 

func (l *LocalRuleManager) DeleteManager(managerId string) error

func (*LocalRuleManager) DroppedAlertmanagers 

func (l *LocalRuleManager) DroppedAlertmanagers() []*url.URL

func (*LocalRuleManager) RuleGroups 

func (l *LocalRuleManager) RuleGroups() []*rules.Group

func (*LocalRuleManager) UpsertRuleGroup 

func (l *LocalRuleManager) UpsertRuleGroup(managerId string, ruleGroup *rulesclient.RuleGroup) error

type ManagerStoreError 

type ManagerStoreError string

func (ManagerStoreError) Error 

func (e ManagerStoreError) Error() string

type PromManagerWrapper 

type PromManagerWrapper interface {
	Start() error
	Reload() error

	// prometheus api v1 rulesRetriever
	RuleGroups() []*rules.Group
	AlertingRules() []*rules.AlertingRule

	// prometheus api v1 alertmanagerRetriever
	Alertmanagers() []*url.URL
	DroppedAlertmanagers() []*url.URL
}

type PromRuleManager 

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

func NewPromRuleManager 

func NewPromRuleManager(managerId, promRuleFile, alertmanagerAddr string, evaluationInterval time.Duration, store storage.Storage, engine *promql.Engine, log *logger.Logger, metrics debug.MetricRegistrar, queryTimeout time.Duration) *PromRuleManager

func (*PromRuleManager) AlertingRules 

func (r *PromRuleManager) AlertingRules() []*rules.AlertingRule

func (*PromRuleManager) Alertmanagers 

func (r *PromRuleManager) Alertmanagers() []*url.URL

func (*PromRuleManager) DroppedAlertmanagers 

func (r *PromRuleManager) DroppedAlertmanagers() []*url.URL

func (*PromRuleManager) Reload 

func (r *PromRuleManager) Reload() error

func (*PromRuleManager) RuleGroups 

func (r *PromRuleManager) RuleGroups() []*rules.Group

func (*PromRuleManager) Start 

func (r *PromRuleManager) Start() error

func (*PromRuleManager) Stop 

func (r *PromRuleManager) Stop() error

type PromRuleManagers 

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

func NewRuleManagers 

func NewRuleManagers(store storage.Storage, engine *promql.Engine, evaluationInterval time.Duration, log *logger.Logger, metrics debug.MetricRegistrar, queryTimeout time.Duration) *PromRuleManagers

func (*PromRuleManagers) AlertingRules 

func (r *PromRuleManagers) AlertingRules() []*rules.AlertingRule

func (*PromRuleManagers) Alertmanagers 

func (r *PromRuleManagers) Alertmanagers() []*url.URL

func (*PromRuleManagers) Create 

func (r *PromRuleManagers) Create(managerId, promRuleFile, alertmanagerAddr string) error

func (*PromRuleManagers) Delete 

func (r *PromRuleManagers) Delete(managerId string) error

func (*PromRuleManagers) DeleteAll 

func (r *PromRuleManagers) DeleteAll() error

func (*PromRuleManagers) DroppedAlertmanagers 

func (r *PromRuleManagers) DroppedAlertmanagers() []*url.URL

func (*PromRuleManagers) Reload 

func (r *PromRuleManagers) Reload() error

func (*PromRuleManagers) RuleGroups 

func (r *PromRuleManagers) RuleGroups() []*rules.Group

type Registerer 

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

func NewRegisterer 

func NewRegisterer(labels prometheus.Labels, reg prometheus.Registerer) *Registerer

func (*Registerer) MustRegister 

func (r *Registerer) MustRegister(cs ...prometheus.Collector)

func (*Registerer) Register 

func (r *Registerer) Register(c prometheus.Collector) error

func (*Registerer) Unregister 

func (r *Registerer) Unregister(c prometheus.Collector) bool

func (*Registerer) UnregisterAll 

func (r *Registerer) UnregisterAll() bool

type RemoteRuleManager 

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

func NewRemoteRuleManager 

func NewRemoteRuleManager(addr string, tlsConfig *tls.Config) *RemoteRuleManager

func (*RemoteRuleManager) AlertingRules 

func (r *RemoteRuleManager) AlertingRules() []*rules.AlertingRule

func (*RemoteRuleManager) Alertmanagers 

func (r *RemoteRuleManager) Alertmanagers() []*url.URL

func (*RemoteRuleManager) CreateManager 

func (r *RemoteRuleManager) CreateManager(managerId, alertmanagerAddr string) error

func (*RemoteRuleManager) DeleteManager 

func (r *RemoteRuleManager) DeleteManager(managerId string) error

func (*RemoteRuleManager) DroppedAlertmanagers 

func (r *RemoteRuleManager) DroppedAlertmanagers() []*url.URL

func (*RemoteRuleManager) RuleGroups 

func (r *RemoteRuleManager) RuleGroups() []*rules.Group

func (*RemoteRuleManager) UpsertRuleGroup 

func (r *RemoteRuleManager) UpsertRuleGroup(managerId string, ruleGroup *rulesclient.RuleGroup) error

type ReplicatedRuleManager 

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

func NewReplicatedRuleManager 

func NewReplicatedRuleManager(localRuleManager RuleManager, localIndex int, addrs []string, replicationFactor uint, tlsConfig *tls.Config) *ReplicatedRuleManager

func (*ReplicatedRuleManager) AlertingRules 

func (r *ReplicatedRuleManager) AlertingRules() []*rules.AlertingRule

TODO: dedup alerts used for /api/v1/alerts

func (*ReplicatedRuleManager) Alertmanagers 

func (r *ReplicatedRuleManager) Alertmanagers() []*url.URL

func (*ReplicatedRuleManager) CreateManager 

func (r *ReplicatedRuleManager) CreateManager(managerId, alertmanagerAddr string) error

func (*ReplicatedRuleManager) DeleteManager 

func (r *ReplicatedRuleManager) DeleteManager(managerId string) error

func (*ReplicatedRuleManager) DroppedAlertmanagers 

func (r *ReplicatedRuleManager) DroppedAlertmanagers() []*url.URL

func (*ReplicatedRuleManager) RuleGroups 

func (r *ReplicatedRuleManager) RuleGroups() []*rules.Group

TODO: dedup rules used for /api/v1/rules

func (*ReplicatedRuleManager) UpsertRuleGroup 

func (r *ReplicatedRuleManager) UpsertRuleGroup(managerId string, ruleGroup *rulesclient.RuleGroup) error

type RuleManager 

type RuleManager interface {
	CreateManager(managerId, alertmanagerAddr string) error
	DeleteManager(managerId string) error
	UpsertRuleGroup(managerId string, ruleGroup *rulesclient.RuleGroup) error
	RuleGroups() []*rules.Group
	AlertingRules() []*rules.AlertingRule
	Alertmanagers() []*url.URL
	DroppedAlertmanagers() []*url.URL
}

type RuleManagerFile 

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

func NewRuleManagerFile 

func NewRuleManagerFile(rulesStoragePath string) *RuleManagerFile

func (*RuleManagerFile) Create 

func (f *RuleManagerFile) Create(managerId, alertmanagerAddr string) (string, error)

func (*RuleManagerFile) Delete 

func (f *RuleManagerFile) Delete(managerId string) error

func (*RuleManagerFile) Load 

func (f *RuleManagerFile) Load(managerId string) (string, string, error)

func (*RuleManagerFile) UpsertRuleGroup 

func (f *RuleManagerFile) UpsertRuleGroup(managerId string, ruleGroup *rulefmt.RuleGroup) error

type RuleManagers 

type RuleManagers interface {
	Create(managerId string, managerFile string, alertmanagerAddr string) error
	Delete(managerId string) error
	DeleteAll() error
	Reload() error
	RuleGroups() []*rules.Group
	AlertingRules() []*rules.AlertingRule
	Alertmanagers() []*url.URL
	DroppedAlertmanagers() []*url.URL
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.