rule

Documentation

Index

• Constants
• type AlarmDataSource
• type AlarmRule
  • func (r *AlarmRule) GetAlarmRule() dbmodel.AlarmRule
  • func (r *AlarmRule) Parse() error
  • func (r *AlarmRule) Stop()
• type AlarmTrigger
• type BaseRule
• type CompareRule
  • func (r *CompareRule) Parse() error
  • func (r *CompareRule) Run()
  • func (r *CompareRule) Start()
• type HeartBeatRule
  • func (r *HeartBeatRule) Parse() error
  • func (r *HeartBeatRule) Run()
  • func (r *HeartBeatRule) Start()
• type Manager
  • func NewManager() *Manager
  • func (m *Manager) Start() error
• type ThresholdRule
  • func (r *ThresholdRule) Parse() error
  • func (r *ThresholdRule) Run()
  • func (r *ThresholdRule) Start()
• type TopNRule
  • func (r *TopNRule) Parse() error
  • func (r *TopNRule) Run()
  • func (r *TopNRule) Start()

Constants

const (
	UpdateRuleInterval        = 30 * time.Second
	MaxDelayForUpdateRuleTime = 10 * time.Minute
)

const (
	AlarmTypeHeartBeat = iota
	AlarmTypeThreshold
	AlarmTypeTopN
	AlarmTypeCompare
)

const (
	CompareTypeDifference = iota
	CompareTypeRatio
)

const (
	UpdateCurvesInterval = 600
	AlarmQueryDelay      = 10 // the end of query time range is 10 seconds ago
)

const MaxCompareDays = 7

const MaxTopNLimit = 100

Types

type AlarmDataSource

type AlarmDataSource struct {
	Metric         string            `json:"metric"`
	Tags           map[string]string `json:"tags"`
	DownSample     int64             `json:"down_sample"`
	Aggregation    string            `json:"aggregation"`
	Sort           string            `json:"sort"`             // use for topN rule only
	Limit          int               `json:"limit"`            // use for topN rule only
	CompareType    int               `json:"compare_type"`     // use for compare rule only
	CompareDaysAgo int               `json:"compare_days_ago"` // use for compare rule only
	CompareSeconds int               `json:"compare_seconds"`  // use for compare rule only
}

type AlarmRule

type AlarmRule struct {
	dbmodel.AlarmRule
	// contains filtered or unexported fields
}

func (*AlarmRule) GetAlarmRule

func (r *AlarmRule) GetAlarmRule() dbmodel.AlarmRule

func (*AlarmRule) Parse

func (r *AlarmRule) Parse() error

func (*AlarmRule) Stop

func (r *AlarmRule) Stop()

type AlarmTrigger

type AlarmTrigger struct {
	ErrorCount  int     `json:"error_count"`
	LessThan    float64 `json:"less_than"`
	GreaterThan float64 `json:"greater_than"`
}

type BaseRule

type BaseRule interface {
	GetAlarmRule() dbmodel.AlarmRule
	Parse() error
	Start()
	Stop()
	Run()
}

type CompareRule

type CompareRule struct {
	AlarmRule
	// contains filtered or unexported fields
}

func (*CompareRule) Parse

func (r *CompareRule) Parse() error

func (*CompareRule) Run

func (r *CompareRule) Run()

func (*CompareRule) Start

func (r *CompareRule) Start()

type HeartBeatRule

type HeartBeatRule struct {
	AlarmRule
	// contains filtered or unexported fields
}

func (*HeartBeatRule) Parse

func (r *HeartBeatRule) Parse() error

func (*HeartBeatRule) Run

func (r *HeartBeatRule) Run()

func (*HeartBeatRule) Start

func (r *HeartBeatRule) Start()

type Manager

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

func NewManager

func NewManager() *Manager

func (*Manager) Start

func (m *Manager) Start() error

type ThresholdRule

type ThresholdRule struct {
	AlarmRule
	// contains filtered or unexported fields
}

func (*ThresholdRule) Parse

func (r *ThresholdRule) Parse() error

func (*ThresholdRule) Run

func (r *ThresholdRule) Run()

func (*ThresholdRule) Start

func (r *ThresholdRule) Start()

type TopNRule

type TopNRule struct {
	AlarmRule
}

func (*TopNRule) Parse

func (r *TopNRule) Parse() error

func (*TopNRule) Run

func (r *TopNRule) Run()

func (*TopNRule) Start

func (r *TopNRule) Start()