eval

Documentation

Index

• type AlertRuleWorker
  • func NewAlertRuleWorker(rule *models.AlertRule, datasourceId int64, processor *process.Processor, ...) *AlertRuleWorker
  • func (arw *AlertRuleWorker) Eval()
  • func (arw *AlertRuleWorker) GetHostAnomalyPoint(ruleConfig string) []common.AnomalyPoint
  • func (arw *AlertRuleWorker) GetPromAnomalyPoint(ruleConfig string) []common.AnomalyPoint
  • func (arw *AlertRuleWorker) Hash() string
  • func (arw *AlertRuleWorker) Key() string
  • func (arw *AlertRuleWorker) Prepare()
  • func (arw *AlertRuleWorker) Start()
  • func (arw *AlertRuleWorker) Stop()
• type Scheduler
  • func NewScheduler(isCenter bool, aconf aconf.Alert, ...) *Scheduler
  • func (s *Scheduler) LoopSyncRules(ctx context.Context)

Types

type AlertRuleWorker

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

func NewAlertRuleWorker

func NewAlertRuleWorker(rule *models.AlertRule, datasourceId int64, processor *process.Processor, promClients *prom.PromClientMap, ctx *ctx.Context) *AlertRuleWorker

func (*AlertRuleWorker) Eval

func (arw *AlertRuleWorker) Eval()

func (*AlertRuleWorker) GetHostAnomalyPoint

func (arw *AlertRuleWorker) GetHostAnomalyPoint(ruleConfig string) []common.AnomalyPoint

func (*AlertRuleWorker) GetPromAnomalyPoint

func (arw *AlertRuleWorker) GetPromAnomalyPoint(ruleConfig string) []common.AnomalyPoint

func (*AlertRuleWorker) Hash

func (arw *AlertRuleWorker) Hash() string

func (*AlertRuleWorker) Key

func (arw *AlertRuleWorker) Key() string

func (*AlertRuleWorker) Prepare

func (arw *AlertRuleWorker) Prepare()

func (*AlertRuleWorker) Start

func (arw *AlertRuleWorker) Start()

func (*AlertRuleWorker) Stop

func (arw *AlertRuleWorker) Stop()

type Scheduler

type Scheduler struct {
	ExternalProcessors *process.ExternalProcessorsType
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(isCenter bool, aconf aconf.Alert, externalProcessors *process.ExternalProcessorsType, arc *memsto.AlertRuleCacheType, targetCache *memsto.TargetCacheType,
	busiGroupCache *memsto.BusiGroupCacheType, alertMuteCache *memsto.AlertMuteCacheType, datasourceCache *memsto.DatasourceCacheType, promClients *prom.PromClientMap, naming *naming.Naming,
	ctx *ctx.Context, stats *astats.Stats) *Scheduler

func (*Scheduler) LoopSyncRules

func (s *Scheduler) LoopSyncRules(ctx context.Context)