monitor

Documentation

Index

• type Dao
  • func New(c *conf.Config) (dao *Dao)
  • func (d *Dao) AddToDelArc(c context.Context, a *monitor.BinlogArchive) (err error)
  • func (d *Dao) AddToSet(c context.Context, keys []string, oid int64) (logs []string, err error)
  • func (d *Dao) ArcDelInfos(c context.Context, aids []int64) (infos map[int64]*monitor.DelArcInfo, err error)
  • func (d *Dao) ArchiveAttr(c context.Context, aid int64) (addit *monitor.ArchiveAddit, err error)
  • func (d *Dao) ClearExpireSet(c context.Context, keys []string) (logs []string, err error)
  • func (d *Dao) Close()
  • func (d *Dao) MoniRuleOids(c context.Context, id int64, min, max int64) (oidMap map[int64]int, err error)
  • func (d *Dao) MoniRuleStats(c context.Context, id int64, min, max int64) (stats *monitor.Stats, err error)
  • func (d *Dao) Ping(c context.Context) error
  • func (d *Dao) RemFromSet(c context.Context, keys []string, oid int64) (logs []string, err error)
  • func (d *Dao) RulesByBid(c context.Context, bid int64) (rules []*monitor.Rule, err error)
  • func (d *Dao) ValidRules(c context.Context) (rules []*monitor.Rule, err error)

Types

type Dao

type Dao struct {
	URLArcAddit string
	// contains filtered or unexported fields
}

func New

func New(c *conf.Config) (dao *Dao)

New init mysql db

func (*Dao) AddToDelArc

func (d *Dao) AddToDelArc(c context.Context, a *monitor.BinlogArchive) (err error)

AddToDelArc 添加稿件信息到

func (*Dao) AddToSet

func (d *Dao) AddToSet(c context.Context, keys []string, oid int64) (logs []string, err error)

AddToSet add monitor stats

func (*Dao) ArcDelInfos

func (d *Dao) ArcDelInfos(c context.Context, aids []int64) (infos map[int64]*monitor.DelArcInfo, err error)

ArcDelInfos 获取被删除稿件的信息

func (*Dao) ArchiveAttr

func (d *Dao) ArchiveAttr(c context.Context, aid int64) (addit *monitor.ArchiveAddit, err error)

ArchiveAttr 获取稿件都附加属性

func (*Dao) ClearExpireSet

func (d *Dao) ClearExpireSet(c context.Context, keys []string) (logs []string, err error)

ClearExpireSet clear expire stats

func (*Dao) Close

func (d *Dao) Close()

Close close the resource.

func (*Dao) MoniRuleOids

func (d *Dao) MoniRuleOids(c context.Context, id int64, min, max int64) (oidMap map[int64]int, err error)

MoniRuleOids 获取监控的id

func (*Dao) MoniRuleStats

func (d *Dao) MoniRuleStats(c context.Context, id int64, min, max int64) (stats *monitor.Stats, err error)

MoniRuleStats 获取监控统计

func (*Dao) Ping

func (d *Dao) Ping(c context.Context) error

Ping dao ping

func (*Dao) RemFromSet

func (d *Dao) RemFromSet(c context.Context, keys []string, oid int64) (logs []string, err error)

RemFromSet remove monitor stats

func (*Dao) RulesByBid

func (d *Dao) RulesByBid(c context.Context, bid int64) (rules []*monitor.Rule, err error)

RulesByBid 获取某业务的监控

func (*Dao) ValidRules

func (d *Dao) ValidRules(c context.Context) (rules []*monitor.Rule, err error)

ValidRules 获取有效的监控