This commit is contained in:
Thibault bui Koechlin 2020-06-17 23:39:52 +02:00
parent a7cb8d7e27
commit ea787def35

View file

@ -141,7 +141,7 @@ func (n *Node) process(p *types.Event, ctx UnixParserCtx) (bool, error) {
NodeState = true NodeState = true
} }
if n.Profiling && n.Name != "" { if n.Name != "" {
NodesHits.With(prometheus.Labels{"source": p.Line.Src, "name": n.Name}).Inc() NodesHits.With(prometheus.Labels{"source": p.Line.Src, "name": n.Name}).Inc()
} }
set := false set := false
@ -285,14 +285,14 @@ func (n *Node) process(p *types.Event, ctx UnixParserCtx) (bool, error) {
//grok or leafs failed, don't process statics //grok or leafs failed, don't process statics
if !NodeState { if !NodeState {
if n.Profiling && n.Name != "" { if n.Name != "" {
NodesHitsKo.With(prometheus.Labels{"source": p.Line.Src, "name": n.Name}).Inc() NodesHitsKo.With(prometheus.Labels{"source": p.Line.Src, "name": n.Name}).Inc()
} }
clog.Debugf("Event leaving node : ko") clog.Debugf("Event leaving node : ko")
return NodeState, nil return NodeState, nil
} }
if n.Profiling && n.Name != "" { if n.Name != "" {
NodesHitsOk.With(prometheus.Labels{"source": p.Line.Src, "name": n.Name}).Inc() NodesHitsOk.With(prometheus.Labels{"source": p.Line.Src, "name": n.Name}).Inc()
} }
if len(n.Statics) > 0 { if len(n.Statics) > 0 {