engine

Documentation

Index

• Variables
• func IsMuted(event *models.AlertCurEvent, clock ...int64) bool
• func LogEvent(event *models.AlertCurEvent, location string, err ...error)
• func Reload()
• func Report(errorType ErrorType)
• func Start(ctx context.Context) error
• func StringSetKeys(m map[string]struct{}) []string
• type AlertCurEventMap
  • func NewAlertCurEventMap() *AlertCurEventMap
  • func (a *AlertCurEventMap) Delete(key string)
  • func (a *AlertCurEventMap) Get(key string) (*models.AlertCurEvent, bool)
  • func (a *AlertCurEventMap) GetAll() map[string]*models.AlertCurEvent
  • func (a *AlertCurEventMap) Keys() []string
  • func (a *AlertCurEventMap) Set(key string, value *models.AlertCurEvent)
  • func (a *AlertCurEventMap) SetAll(data map[string]*models.AlertCurEvent)
  • func (a *AlertCurEventMap) UpdateLastEvalTime(key string, lastEvalTime int64)
• type ErrorType
• type MaintainMessage
• type Notice
• type RecordingRuleEval
  • func (r RecordingRuleEval) RuleID() int64
  • func (r RecordingRuleEval) Start()
  • func (r RecordingRuleEval) Stop()
  • func (r RecordingRuleEval) Work()
• type RuleEval
  • func (r *RuleEval) Judge(clusterName string, vectors []conv.Vector)
  • func (r *RuleEval) MakeNewEvent(from string, now int64, clusterName string, vectors []conv.Vector) (map[string]struct{}, bool)
  • func (r *RuleEval) RecoverEvent(hash string, now int64, value float64)
  • func (r *RuleEval) RuleID() int64
  • func (r *RuleEval) Start()
  • func (r *RuleEval) Stop()
  • func (r *RuleEval) Work()
• type RuleEvalForExternalType
  • func (re *RuleEvalForExternalType) Build()
  • func (re *RuleEvalForExternalType) Get(rid int64) (RuleEval, bool)
• type TaskCreateReply
• type TaskForm
• type WorkersType
  • func (ws *WorkersType) Build(rids []int64)
  • func (ws *WorkersType) BuildRe(rids []int64)

Variables

var EventQueue = list.NewSafeListLimited(10000000)

var RuleEvalForExternal = RuleEvalForExternalType{/* contains filtered or unexported fields */}

var Workers = &WorkersType{rules: make(map[string]*RuleEval), recordRules: make(map[string]RecordingRuleEval)}

Functions

func IsMuted

func IsMuted(event *models.AlertCurEvent, clock ...int64) bool

如果传入了clock这个可选参数，就表示使用这个clock表示的时间，否则就从event的字段中取TriggerTime

func LogEvent

func LogEvent(event *models.AlertCurEvent, location string, err ...error)

func Reload

func Reload()

func Report

func Report(errorType ErrorType)

func Start

func Start(ctx context.Context) error

func StringSetKeys

func StringSetKeys(m map[string]struct{}) []string

Types

type AlertCurEventMap

type AlertCurEventMap struct {
	sync.RWMutex
	Data map[string]*models.AlertCurEvent
}

func NewAlertCurEventMap

func NewAlertCurEventMap() *AlertCurEventMap

func (*AlertCurEventMap) Delete

func (a *AlertCurEventMap) Delete(key string)

func (*AlertCurEventMap) Get

func (a *AlertCurEventMap) Get(key string) (*models.AlertCurEvent, bool)

func (*AlertCurEventMap) GetAll

func (a *AlertCurEventMap) GetAll() map[string]*models.AlertCurEvent

func (*AlertCurEventMap) Keys

func (a *AlertCurEventMap) Keys() []string

func (*AlertCurEventMap) Set

func (a *AlertCurEventMap) Set(key string, value *models.AlertCurEvent)

func (*AlertCurEventMap) SetAll

func (a *AlertCurEventMap) SetAll(data map[string]*models.AlertCurEvent)

func (*AlertCurEventMap) UpdateLastEvalTime

func (a *AlertCurEventMap) UpdateLastEvalTime(key string, lastEvalTime int64)

type ErrorType

type ErrorType string

const (
	QueryPrometheusError ErrorType = "QueryPrometheusError"
	RuntimeError         ErrorType = "RuntimeError"
)

register new error here

type MaintainMessage

type MaintainMessage struct {
	Tos     []*models.User `json:"tos"`
	Title   string         `json:"title"`
	Content string         `json:"content"`
}

type Notice

type Notice struct {
	Event *models.AlertCurEvent `json:"event"`
	Tpls  map[string]string     `json:"tpls"`
}

type RecordingRuleEval

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

func (RecordingRuleEval) RuleID

func (r RecordingRuleEval) RuleID() int64

func (RecordingRuleEval) Start

func (r RecordingRuleEval) Start()

func (RecordingRuleEval) Stop

func (r RecordingRuleEval) Stop()

func (RecordingRuleEval) Work

func (r RecordingRuleEval) Work()

type RuleEval

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

func (*RuleEval) Judge

func (r *RuleEval) Judge(clusterName string, vectors []conv.Vector)

func (*RuleEval) MakeNewEvent

func (r *RuleEval) MakeNewEvent(from string, now int64, clusterName string, vectors []conv.Vector) (map[string]struct{}, bool)

func (*RuleEval) RecoverEvent

func (r *RuleEval) RecoverEvent(hash string, now int64, value float64)

func (*RuleEval) RuleID

func (r *RuleEval) RuleID() int64

func (*RuleEval) Start

func (r *RuleEval) Start()

func (*RuleEval) Stop

func (r *RuleEval) Stop()

func (*RuleEval) Work

func (r *RuleEval) Work()

type RuleEvalForExternalType

type RuleEvalForExternalType struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*RuleEvalForExternalType) Build

func (re *RuleEvalForExternalType) Build()

func (*RuleEvalForExternalType) Get

func (re *RuleEvalForExternalType) Get(rid int64) (RuleEval, bool)

type TaskCreateReply

type TaskCreateReply struct {
	Err string `json:"err"`
	Dat int64  `json:"dat"` // task.id
}

type TaskForm

type TaskForm struct {
	Title     string   `json:"title"`
	Account   string   `json:"account"`
	Batch     int      `json:"batch"`
	Tolerance int      `json:"tolerance"`
	Timeout   int      `json:"timeout"`
	Pause     string   `json:"pause"`
	Script    string   `json:"script"`
	Args      string   `json:"args"`
	Action    string   `json:"action"`
	Creator   string   `json:"creator"`
	Hosts     []string `json:"hosts"`
}

type WorkersType

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

func (*WorkersType) Build

func (ws *WorkersType) Build(rids []int64)

func (*WorkersType) BuildRe

func (ws *WorkersType) BuildRe(rids []int64)