feat: prometheusIngester sends user-agent header (#95)

* feat: prometheusIngester sends user-agent header

Co-authored-by: Vlk, Ondrej <[email protected]>

Author: FuFikCZ

CHANGELOG.md

@@ -5,6 +5,11 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## Unreleased
+
+## [v6.12.1] 2022-10-14
+### Added
+- [#95](https://github.com/seznam/slo-exporter/pull/95) prometheusIngester sends user-agent header
+
 ### Fixed
 - [#96](https://github.com/seznam/slo-exporter/pull/96) prometheusIngester headers from environment value now works
 

cmd/slo_exporter.go

@@ -68,7 +68,7 @@ func moduleFactory(moduleName string, logger logrus.FieldLogger, conf *viper.Vip
 	case "tailer":
 		return tailer.NewFromViper(conf, logger)
 	case "prometheusIngester":
-		return prometheus_ingester.NewFromViper(conf, logger)
+		return prometheus_ingester.NewFromViper(conf, logger, version)
 	case "kafkaIngester":
 		return kafka_ingester.NewFromViper(conf, logger)
 	case "envoyAccessLogServer":

pkg/prometheus_ingester/prometheus_ingester.go

@@ -171,11 +171,19 @@ func (i *PrometheusIngester) OutputChannel() chan *event.Raw {
 	return i.outputChannel
 }
 
-func NewFromViper(viperAppConfig *viper.Viper, logger logrus.FieldLogger) (*PrometheusIngester, error) {
+func NewFromViper(viperAppConfig *viper.Viper, logger logrus.FieldLogger, appVersion string) (*PrometheusIngester, error) {
 	config := PrometheusIngesterConfig{}
+
 	if err := viperAppConfig.UnmarshalExact(&config); err != nil {
 		return nil, fmt.Errorf("failed to load configuration: %w", err)
 	}
+
+	userAgent := "slo-exporter/" + appVersion
+	config.HttpHeaders = append(config.HttpHeaders, httpHeader{
+		Name:  "user-agent",
+		Value: &userAgent,
+	})
+
 	if config.Staleness == time.Duration(0) {
 		config.Staleness = defaultStaleness
 	}