eval

Documentation

Index

• Constants
• 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) GetTdengineAnomalyPoint(rule *models.AlertRule, dsId int64) ([]common.AnomalyPoint, []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(aconf aconf.Alert, externalProcessors *process.ExternalProcessorsType, ...) *Scheduler
  • func (s *Scheduler) LoopSyncRules(ctx context.Context)

Constants

const (
	GET_RULE_CONFIG = "get_rule_config"
	GET_PROCESSOR   = "get_processor"
	CHECK_QUERY     = "check_query_config"
	GET_CLIENT      = "get_client"
	QUERY_DATA      = "query_data"
)

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, tdengineClients *tdengine.TdengineClientMap, 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) GetTdengineAnomalyPoint

func (arw *AlertRuleWorker) GetTdengineAnomalyPoint(rule *models.AlertRule, dsId int64) ([]common.AnomalyPoint, []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(aconf aconf.Alert, externalProcessors *process.ExternalProcessorsType, arc *memsto.AlertRuleCacheType, targetCache *memsto.TargetCacheType,
	busiGroupCache *memsto.BusiGroupCacheType, alertMuteCache *memsto.AlertMuteCacheType, datasourceCache *memsto.DatasourceCacheType,
	promClients *prom.PromClientMap, tdengineClients *tdengine.TdengineClientMap, naming *naming.Naming, ctx *ctx.Context, stats *astats.Stats) *Scheduler

func (*Scheduler) LoopSyncRules

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