dao

Documentation

Index

• Variables
• func AlertSentinelStart()
• func CronTrigger(cr model.Cron) func()
• func LoadNotifications()
• func ManualTrigger(c model.Cron)
• func NewServiceSentinel(serviceSentinelDispatchBus chan<- model.Monitor)
• func OnDeleteAlert(id uint64)
• func OnDeleteNotification(id uint64)
• func OnRefreshOrAddAlert(alert model.AlertRule)
• func OnRefreshOrAddNotification(n model.Notification)
• func ReSortServer()
• func SendNotification(desc string, muteable bool)
• type NotificationHistory
• type ReportData
• type ServiceSentinel
  • func (ss *ServiceSentinel) Dispatch(r ReportData)
  • func (ss *ServiceSentinel) LoadStats() map[uint64]*model.ServiceItemResponse
  • func (ss *ServiceSentinel) Monitors() []*model.Monitor
  • func (ss *ServiceSentinel) OnMonitorDelete(id uint64)
  • func (ss *ServiceSentinel) OnMonitorUpdate(m model.Monitor) error

Variables

var (
	Conf  *model.Config
	Cache *cache.Cache
	DB    *gorm.DB

	ServerList map[uint64]*model.Server
	SecretToID map[string]uint64
	ServerLock sync.RWMutex

	SortedServerList []*model.Server
	SortedServerLock sync.RWMutex
)

var Alerts []*model.AlertRule

var AlertsCycleTransferStatsStore map[uint64]*model.CycleTransferStats

var AlertsLock sync.RWMutex

报警规则

var Cron *cron.Cron

var CronLock sync.RWMutex

var Crons map[uint64]*model.Cron

var Version = "v0.12.2" // ！！记得修改 README 中的 badge 版本！！

Functions

func AlertSentinelStart

func AlertSentinelStart()

func CronTrigger

func CronTrigger(cr model.Cron) func()

func LoadNotifications

func LoadNotifications()

func ManualTrigger

func ManualTrigger(c model.Cron)

func NewServiceSentinel

func NewServiceSentinel(serviceSentinelDispatchBus chan<- model.Monitor)

func OnDeleteAlert

func OnDeleteAlert(id uint64)

func OnDeleteNotification

func OnDeleteNotification(id uint64)

func OnRefreshOrAddAlert

func OnRefreshOrAddAlert(alert model.AlertRule)

func OnRefreshOrAddNotification

func OnRefreshOrAddNotification(n model.Notification)

func ReSortServer

func ReSortServer()

func SendNotification

func SendNotification(desc string, muteable bool)

Types

type NotificationHistory

type NotificationHistory struct {
	Duration time.Duration
	Until    time.Time
}

type ReportData

type ReportData struct {
	Data     *pb.TaskResult
	Reporter uint64
}

type ServiceSentinel

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

使用缓存 channel，处理上报的 Service 请求结果，然后判断是否需要报警 需要记录上一次的状态信息

var ServiceSentinelShared *ServiceSentinel

func (*ServiceSentinel) Dispatch

func (ss *ServiceSentinel) Dispatch(r ReportData)

func (*ServiceSentinel) LoadStats

func (ss *ServiceSentinel) LoadStats() map[uint64]*model.ServiceItemResponse

func (*ServiceSentinel) Monitors

func (ss *ServiceSentinel) Monitors() []*model.Monitor

func (*ServiceSentinel) OnMonitorDelete

func (ss *ServiceSentinel) OnMonitorDelete(id uint64)

func (*ServiceSentinel) OnMonitorUpdate

func (ss *ServiceSentinel) OnMonitorUpdate(m model.Monitor) error