本文整理汇总了Golang中github.com/eliothedeman/bangarang/event.Event类的典型用法代码示例。如果您正苦于以下问题:Golang Event类的具体用法?Golang Event怎么用?Golang Event使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Event类的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: CheckNotMatch
func (p *Policy) CheckNotMatch(e *event.Event) bool {
for k, m := range p.r_not_match {
if m.MatchString(e.Get(k)) {
return false
}
}
return true
}
开发者ID:postfix,项目名称:bangarang,代码行数:8,代码来源:policy.go
示例2: CheckMatch
// check if any of p's matches are satisfied by the event
func (p *Policy) CheckMatch(e *event.Event) bool {
for k, m := range p.r_match {
// if the element does not match the regex pattern, the event does not fully match
if !m.MatchString(e.Get(k)) {
return false
}
}
return true
}
开发者ID:postfix,项目名称:bangarang,代码行数:10,代码来源:policy.go
示例3: DoOnTracker
func (c *Condition) DoOnTracker(e *event.Event, dot func(*eventTracker)) {
// c.Lock()
et, ok := c.eventTrackers[e.IndexName()]
if !ok {
et = c.newTracker()
c.eventTrackers[e.IndexName()] = et
}
dot(et)
// c.Unlock()
}
开发者ID:nolenroyalty,项目名称:bangarang,代码行数:10,代码来源:condition.go
示例4: trackEvent
func (t *Tracker) trackEvent(e *event.Event) {
// don't track internal events
if len(e.Get(INTERNAL_TAG_NAME)) != 0 {
return
}
t.total.inc()
t.updateCounts(e)
t.updateTimes(e)
}
开发者ID:nolenroyalty,项目名称:bangarang,代码行数:11,代码来源:tracker.go
示例5: getTracker
func (c *Condition) getTracker(e *event.Event) *eventTracker {
if c.eventTrackers == nil {
c.eventTrackers = make(map[string]*eventTracker)
}
et, ok := c.eventTrackers[e.IndexName()]
if !ok {
et = c.newTracker()
c.eventTrackers[e.IndexName()] = et
}
return et
}
开发者ID:nolenroyalty,项目名称:bangarang,代码行数:12,代码来源:condition.go
示例6: processEvent
// Run the given event though the pipeline
func (p *Pipeline) processEvent(e *event.Event) {
// update to current state
e.SetState(event.StatePipeline)
// track stas for this event
p.tracker.TrackEvent(e)
// process this event on every policy
var pol *escalation.Policy
for _, pol = range p.policies {
pol.PassEvent(e)
}
}
开发者ID:nolenroyalty,项目名称:bangarang,代码行数:15,代码来源:pipeline.go
示例7: Process
// Run the given event though the pipeline
func (p *Pipeline) Process(e *event.Event) {
if p.globalPolicy != nil {
if !p.globalPolicy.CheckMatch(e) || !p.globalPolicy.CheckNotMatch(e) {
return
}
}
// track stas for this event
p.tracker.TrackEvent(e)
// process this event on every policy
var pol *alarm.Policy
for _, pol = range p.policies {
e.WaitInc()
pol.Process(e, func(in *event.Incident) {
p.ProcessIncident(in)
})
}
}
开发者ID:postfix,项目名称:bangarang,代码行数:21,代码来源:pipeline.go
示例8: start
// start the policy listening for events
func (p *Policy) start() {
go func() {
var e *event.Event
for {
select {
case toResolve := <-p.resolve:
var c *Condition
// fetch the condition that created this incident
if toResolve.Status == event.CRITICAL {
c = p.Crit
} else if toResolve.Status == event.WARNING {
c = p.Warn
}
if c != nil {
t := c.getTracker(&toResolve.Event)
t.refresh()
}
case <-p.stop:
logrus.Info("Stopping policy", p.Name)
// cleanup the policy. Sometimes they hangaround.
p.clean()
// stop this policy from being stopped again
p.stop = nil
// catch resolve's that could be sent to this policy
res := p.resolve
p.resolve = nil
go func() {
for {
select {
case <-res:
logrus.Info("Attempted to resolve an incident on a policy that no longer exists")
case <-time.After(1 * time.Minute):
return
}
}
}()
return
case e = <-p.in:
e.SetState(event.StatePolicy)
// process the event if it matches the policy
if p.Matches(e) {
// check critical
if shouldAlert, status := p.ActionCrit(e); shouldAlert {
incident := event.NewIncident(p.Name, status, e)
incident.SetResolve(p.resolve)
// send send it off to the next hop
p.next.PassIncident(incident)
// check warning
} else if shouldAlert, status := p.ActionWarn(e); shouldAlert {
incident := event.NewIncident(p.Name, status, e)
incident.SetResolve(p.resolve)
// send it off to the next hop
p.next.PassIncident(incident)
} else {
e.SetState(event.StateComplete)
}
}
}
}
}()
}
开发者ID:nolenroyalty,项目名称:bangarang,代码行数:77,代码来源:policy.go
示例9: genIndexName
// generate an index name by using group-by statements
func (g grouper) genIndexName(e *event.Event) string {
return e.IndexName()
}
开发者ID:postfix,项目名称:bangarang,代码行数:5,代码来源:condition.go
注:本文中的github.com/eliothedeman/bangarang/event.Event类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论