Method bumpNodeMetric

pkg/parser/node.go:530–545

(counter *prometheus.CounterVec, p *pipeline.Event)

}

func (n *Node) bumpNodeMetric(counter *prometheus.CounterVec, p *pipeline.Event) {
	// better safe than sorry
	acquisType := p.Line.Labels["type"]
	if acquisType == "" {
		acquisType = "unknown"
	}

	labels := prometheus.Labels{
		"source":      p.Line.Src,
		"type":        p.Line.Module,
		"name":        n.Name,
		"stage":       p.Stage,
		"acquis_type": acquisType,
	}
	counter.With(labels).Inc()
}