Index: head/net-mgmt/nsd_exporter/Makefile =================================================================== --- head/net-mgmt/nsd_exporter/Makefile (revision 496268) +++ head/net-mgmt/nsd_exporter/Makefile (revision 496269) @@ -1,55 +1,56 @@ # Created by: Ryan Steinmetz # $FreeBSD$ PORTNAME= nsd_exporter PORTVERSION= 0.1.0 -PORTREVISION= 1 +PORTREVISION= 2 CATEGORIES= net-mgmt MAINTAINER= zi@FreeBSD.org COMMENT= Prometheus exporter for nsd metrics LICENSE= BSD3CLAUSE USES= go USE_GITHUB= yes GH_ACCOUNT= optix2000 GH_TUPLE= prometheus:client_golang:v0.8.0:client_golang \ prometheus:client_model:5c3871d:client_model \ prometheus:procfs:ae68e2d:procfs \ prometheus:common:7600349:common \ beorn7:perks:3a771d9:perks \ golang:protobuf:70b3af3:protobuf \ matttproud:golang_protobuf_extensions:c12348c:golang_protobuf_extensions \ optix2000:go-nsdctl:ce14b32:go_nsdctl \ go-yaml:yaml:7f97868:go_yaml GO_PKGNAME= github.com/${GH_ACCOUNT}/${PORTNAME} GO_TARGET= github.com/${GH_ACCOUNT}/${PORTNAME} PLIST_FILES= bin/nsd_exporter USE_RC_SUBR= nsd_exporter post-patch: ${REINPLACE_CMD} -e 's|"/etc|"${LOCALBASE}/etc|g' ${WRKSRC_go_nsdctl}/nsdctl.go + ${REINPLACE_CMD} -e 's|"/etc|"${LOCALBASE}/etc|g' ${WRKSRC}/nsd_exporter.go pre-build: ${MKDIR} ${GO_WRKDIR_SRC}/github.com/prometheus ${GO_WRKDIR_SRC}/gopkg.in \ ${GO_WRKDIR_SRC}/github.com/beorn7 ${GO_WRKDIR_SRC}/github.com/golang \ ${GO_WRKDIR_SRC}/github.com/matttproud ${GO_WRKDIR_SRC}/github.com/optix2000 ${MV} ${WRKSRC_golang_protobuf_extensions} ${GO_WRKDIR_SRC}/github.com/matttproud/golang_protobuf_extensions ${MV} ${WRKSRC_go_nsdctl} ${GO_WRKDIR_SRC}/github.com/optix2000/go-nsdctl ${MV} ${WRKSRC_client_golang} ${GO_WRKDIR_SRC}/github.com/prometheus/client_golang ${MV} ${WRKSRC_client_model} ${GO_WRKDIR_SRC}/github.com/prometheus/client_model ${MV} ${WRKSRC_procfs} ${GO_WRKDIR_SRC}/github.com/prometheus/procfs ${MV} ${WRKSRC_common} ${GO_WRKDIR_SRC}/github.com/prometheus/common ${MV} ${WRKSRC_protobuf} ${GO_WRKDIR_SRC}/github.com/golang/protobuf ${MV} ${WRKSRC_go_yaml} ${GO_WRKDIR_SRC}/gopkg.in/yaml.v2 ${MV} ${WRKSRC_perks} ${GO_WRKDIR_SRC}/github.com/beorn7/perks do-install: ${INSTALL_PROGRAM} ${WRKDIR}/bin/nsd_exporter ${STAGEDIR}${PREFIX}/bin .include Index: head/net-mgmt/nsd_exporter/distinfo =================================================================== --- head/net-mgmt/nsd_exporter/distinfo (revision 496268) +++ head/net-mgmt/nsd_exporter/distinfo (revision 496269) @@ -1,21 +1,21 @@ -TIMESTAMP = 1551277938 +TIMESTAMP = 1553011211 SHA256 (optix2000-nsd_exporter-0.1.0_GH0.tar.gz) = 7fb9fae9f434e904e79eceaef9e5640e8be66d57384f87a9a6a85ab663dcf51c SIZE (optix2000-nsd_exporter-0.1.0_GH0.tar.gz) = 8144 SHA256 (prometheus-client_golang-v0.8.0_GH0.tar.gz) = 88b0040393276116f848de5bdd636717d339667273cfc45a4edda40b5e5682bd SIZE (prometheus-client_golang-v0.8.0_GH0.tar.gz) = 75593 SHA256 (prometheus-client_model-5c3871d_GH0.tar.gz) = 5decfffcc4a7cfbce4214e42aaf0e3af9acdadf5d3f3ef6733868314171fd2f0 SIZE (prometheus-client_model-5c3871d_GH0.tar.gz) = 57126 SHA256 (prometheus-procfs-ae68e2d_GH0.tar.gz) = d2ef0107607a9e0fcfccbe7d0a364ea04de741d464b244994fb579f2610dfb4f SIZE (prometheus-procfs-ae68e2d_GH0.tar.gz) = 57790 SHA256 (prometheus-common-7600349_GH0.tar.gz) = 428d2301007b765ae36a64114b2f4806556c602dba34c011a10caaae76cbb433 SIZE (prometheus-common-7600349_GH0.tar.gz) = 77805 SHA256 (beorn7-perks-3a771d9_GH0.tar.gz) = b7a0faebca98ebd5e7546403b4cdea9dc77f865f0623d04efbad33e984297cc9 SIZE (beorn7-perks-3a771d9_GH0.tar.gz) = 10800 SHA256 (golang-protobuf-70b3af3_GH0.tar.gz) = fd81970d30eba8f3d49c5b27eb80728060f022bb391515e8d79724d5b39dc1f9 SIZE (golang-protobuf-70b3af3_GH0.tar.gz) = 329777 SHA256 (matttproud-golang_protobuf_extensions-c12348c_GH0.tar.gz) = da165c9275b77a0994b815bc7d761dcb2e4799a90fe49eec08d8bdff3a683f48 SIZE (matttproud-golang_protobuf_extensions-c12348c_GH0.tar.gz) = 37200 SHA256 (optix2000-go-nsdctl-ce14b32_GH0.tar.gz) = 4474f6e9f18d08035f36ef60dc25b97c7c5528ab99f59cf7f94854613d73b239 SIZE (optix2000-go-nsdctl-ce14b32_GH0.tar.gz) = 4038 SHA256 (go-yaml-yaml-7f97868_GH0.tar.gz) = b0215657c82db81fa1e10f73fb1df3db12715ec68a14ab555e7f40d1d174132d SIZE (go-yaml-yaml-7f97868_GH0.tar.gz) = 69163 Index: head/net-mgmt/nsd_exporter/files/patch-nsd__exporter.go =================================================================== --- head/net-mgmt/nsd_exporter/files/patch-nsd__exporter.go (revision 496268) +++ head/net-mgmt/nsd_exporter/files/patch-nsd__exporter.go (revision 496269) @@ -1,20 +1,163 @@ --- nsd_exporter.go.orig 2018-02-08 23:45:14 UTC +++ nsd_exporter.go -@@ -19,7 +19,7 @@ import ( - var listenAddr = flag.String("listen-address", ":8080", "The address to listen on for HTTP requests.") - var metricPath = flag.String("metric-path", "/metrics", "The path to export Prometheus metrocs to.") - var metricConfigPath = flag.String("metric-config", "", "Mapping file for metrics. Defaults to built in file for NSD 4.1.x. This allows you to add or change any metrics that this scrapes") --var nsdConfig = flag.String("config-file", "/etc/nsd/nsd.conf", "Configuration file for nsd/unbound to autodetect configuration from. Defaults to /etc/nsd/nsd.conf. Mutually exclusive with -nsd-address, -cert, -key and -ca") -+var nsdConfig = flag.String("config-file", "/usr/local/etc/nsd/nsd.conf", "Configuration file for nsd/unbound to autodetect configuration from. Defaults to /usr/local/etc/nsd/nsd.conf. Mutually exclusive with -nsd-address, -cert, -key and -ca") - var nsdType = flag.String("type", "nsd", "What nsd-like daemon to scrape (nsd or unbound). Defaults to nsd") - var cert = flag.String("cert", "", "Client cert file location. Mutually exclusive with -config-file.") - var key = flag.String("key", "", "Client key file location. Mutually exclusive with -config-file.") -@@ -58,7 +58,7 @@ func (c *NSDCollector) Collect(ch chan<- +@@ -5,6 +5,7 @@ package main + import ( + "bufio" + "flag" ++ "fmt" + "log" + "net/http" + "strconv" +@@ -58,10 +59,20 @@ func (c *NSDCollector) Collect(ch chan<- s := bufio.NewScanner(r) for s.Scan() { line := strings.Split(s.Text(), "=") - metricName := line[0] + metricName := strings.TrimSpace(line[0]) m, ok := c.metrics[metricName] if !ok { - log.Println("Unknown Metric ", metricName, ". Skipping.") +- log.Println("Unknown Metric ", metricName, ". Skipping.") ++ log.Println("New metric " + metricName + " found. Refreshing.") ++ // Try to update the metrics list ++ err = c.updateMetric(s.Text()) ++ if err != nil { ++ log.Println(err.Error()) ++ } ++ // Refetch metric ++ m, ok = c.metrics[metricName] ++ if !ok { ++ log.Println("Metric " + metricName + "not configured. Skipping") ++ } + continue + } + value, err := strconv.ParseFloat(line[1], 64) +@@ -84,7 +95,57 @@ func (c *NSDCollector) Collect(ch chan<- + + } + +-func (c *NSDCollector) updateMetricsList() error { ++func (c *NSDCollector) updateMetric(s string) error { ++ // Assume line is in "metric=#" format ++ line := strings.Split(s, "=") ++ metricName := strings.TrimSpace(line[0]) ++ ++ _, exists := c.metrics[metricName] ++ if !exists { ++ metricConf, ok := metricConfiguration.Metrics[metricName] ++ if ok { ++ promName := nsdToProm.Replace(line[0]) ++ c.metrics[metricName] = &promMetric{ ++ desc: prometheus.NewDesc( ++ prometheus.BuildFQName(*nsdType, "", promName), ++ metricConf.Help, ++ nil, ++ nil, ++ ), ++ valueType: metricConf.Type, ++ } ++ } else { // Try labeled metric ++ for _, v := range metricConfiguration.LabelMetrics { ++ labels := v.Regex.FindStringSubmatch(metricName) ++ if labels != nil { ++ var promName string ++ if v.Name != "" { ++ promName = v.Name ++ } else { ++ promName = nsdToProm.Replace(line[0]) ++ } ++ c.metrics[metricName] = &promMetric{ ++ desc: prometheus.NewDesc( ++ prometheus.BuildFQName(*nsdType, "", promName), ++ v.Help, ++ v.Labels, ++ nil, ++ ), ++ valueType: v.Type, ++ labels: labels[1:len(labels)], ++ } ++ // python "for-else" ++ goto Found ++ } ++ } ++ return fmt.Errorf("Metric ", metricName, " not found in config.") ++ Found: ++ } ++ } ++ return nil ++} ++ ++func (c *NSDCollector) initMetricsList() error { + r, err := c.client.Command("stats_noreset") + if err != nil { + log.Println(err) +@@ -98,49 +159,9 @@ func (c *NSDCollector) updateMetricsList + // Grab metrics + s := bufio.NewScanner(r) + for s.Scan() { +- // Assume line is in "metric=#" format +- line := strings.Split(s.Text(), "=") +- metricName := line[0] +- +- _, exists := c.metrics[metricName] +- if !exists { +- metricConf, ok := metricConfiguration.Metrics[metricName] +- if ok { +- promName := nsdToProm.Replace(line[0]) +- c.metrics[metricName] = &promMetric{ +- desc: prometheus.NewDesc( +- prometheus.BuildFQName(*nsdType, "", promName), +- metricConf.Help, +- nil, +- nil, +- ), +- valueType: metricConf.Type, +- } +- } else { // Try labeled metric +- for _, v := range metricConfiguration.LabelMetrics { +- // TODO: Move this to Collect(), to catch any metrics that are created at runtime +- // Unfortunately prom needs all metrics defined at the beginning +- labels := v.Regex.FindStringSubmatch(metricName) +- if labels != nil { +- var promName string +- if v.Name != "" { +- promName = v.Name +- } else { +- promName = nsdToProm.Replace(line[0]) +- } +- c.metrics[metricName] = &promMetric{ +- desc: prometheus.NewDesc( +- prometheus.BuildFQName(*nsdType, "", promName), +- v.Help, +- v.Labels, +- nil, +- ), +- valueType: v.Type, +- labels: labels[1:len(labels)], +- } +- } +- } +- } ++ err = c.updateMetric(s.Text()) ++ if err != nil { ++ log.Println(err.Error(), "Skipping.") + } + } + return s.Err() +@@ -156,7 +177,7 @@ func NewNSDCollector(nsdType string, hos + client: client, + } + +- err = collector.updateMetricsList() ++ err = collector.initMetricsList() + if err != nil { + log.Println(err) + return nil, err +@@ -174,7 +195,7 @@ func NewNSDCollectorFromConfig(path stri + client: client, + } + +- err = collector.updateMetricsList() ++ err = collector.initMetricsList() + if err != nil { + log.Println(err) + return nil, err