mirrors/statsd_exporter
1
0
Fork 1
mirror of https://github.com/prometheus/statsd_exporter.git synced 2024-11-26 17:21:01 +00:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #141 from negz/master

Browse source 
Switch to kingpin for flag handling
This commit is contained in:
Matthias Rampke 2018-08-21 10:50:29 +02:00 committed by GitHub
commit 88a7eef426
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 29 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
main.go
View file

@ -14,17 +14,15 @@
package main package main
import ( import (
"flag"
"fmt"
"net" "net"
"net/http" "net/http"
"os"
"strconv" "strconv"
"github.com/howeyc/fsnotify" "github.com/howeyc/fsnotify"
"github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/common/log" "github.com/prometheus/common/log"
"github.com/prometheus/common/version" "github.com/prometheus/common/version"
"gopkg.in/alecthomas/kingpin.v2"
"github.com/prometheus/statsd_exporter/pkg/mapper" "github.com/prometheus/statsd_exporter/pkg/mapper"
) )
@ -33,29 +31,18 @@ func init() {
prometheus.MustRegister(version.NewCollector("statsd_exporter")) prometheus.MustRegister(version.NewCollector("statsd_exporter"))
} }
var ( func serveHTTP(listenAddress, metricsEndpoint string) {
listenAddress = flag.String("web.listen-address", ":9102", "The address on which to expose the web interface and generated Prometheus metrics.") http.Handle(metricsEndpoint, prometheus.Handler())
metricsEndpoint = flag.String("web.telemetry-path", "/metrics", "Path under which to expose metrics.")
statsdListenAddress = flag.String("statsd.listen-address", "", "The UDP address on which to receive statsd metric lines. DEPRECATED, use statsd.listen-udp instead.")
statsdListenUDP = flag.String("statsd.listen-udp", ":9125", "The UDP address on which to receive statsd metric lines. \"\" disables it.")
statsdListenTCP = flag.String("statsd.listen-tcp", ":9125", "The TCP address on which to receive statsd metric lines. \"\" disables it.")
mappingConfig = flag.String("statsd.mapping-config", "", "Metric mapping configuration file name.")
readBuffer = flag.Int("statsd.read-buffer", 0, "Size (in bytes) of the operating system's transmit read buffer associated with the UDP connection. Please make sure the kernel parameters net.core.rmem_max is set to a value greater than the value specified.")
showVersion = flag.Bool("version", false, "Print version information.")
)
func serveHTTP() {
http.Handle(*metricsEndpoint, prometheus.Handler())
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) { http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
w.Write([]byte(`<html> w.Write([]byte(`<html>
<head><title>StatsD Exporter</title></head> <head><title>StatsD Exporter</title></head>
<body> <body>
<h1>StatsD Exporter</h1> <h1>StatsD Exporter</h1>
<p><a href="` + *metricsEndpoint + `">Metrics</a></p> <p><a href="` + metricsEndpoint + `">Metrics</a></p>
</body> </body>
</html>`)) </html>`))
}) })
log.Fatal(http.ListenAndServe(*listenAddress, nil)) log.Fatal(http.ListenAndServe(listenAddress, nil))
} }
func ipPortFromString(addr string) (*net.IPAddr, int) { func ipPortFromString(addr string) (*net.IPAddr, int) {
@ -132,17 +119,19 @@ func watchConfig(fileName string, mapper *mapper.MetricMapper) {
} }
func main() { func main() {
flag.Parse() var (
listenAddress = kingpin.Flag("web.listen-address", "The address on which to expose the web interface and generated Prometheus metrics.").Default(":9102").String()
metricsEndpoint = kingpin.Flag("web.telemetry-path", "Path under which to expose metrics.").Default("/metrics").String()
statsdListenUDP = kingpin.Flag("statsd.listen-udp", "The UDP address on which to receive statsd metric lines. \"\" disables it.").Default(":9125").String()
statsdListenTCP = kingpin.Flag("statsd.listen-tcp", "The TCP address on which to receive statsd metric lines. \"\" disables it.").Default(":9125").String()
mappingConfig = kingpin.Flag("statsd.mapping-config", "Metric mapping configuration file name.").String()
readBuffer = kingpin.Flag("statsd.read-buffer", "Size (in bytes) of the operating system's transmit read buffer associated with the UDP connection. Please make sure the kernel parameters net.core.rmem_max is set to a value greater than the value specified.").Int()
)
if *showVersion { log.AddFlags(kingpin.CommandLine)
fmt.Fprintln(os.Stdout, version.Print("statsd_exporter")) kingpin.Version(version.Print("statsd_exporter"))
os.Exit(0) kingpin.HelpFlag.Short('h')
} kingpin.Parse()
if *statsdListenAddress != "" {
log.Warnln("Warning: statsd.listen-address is DEPRECATED, please use statsd.listen-udp instead.")
*statsdListenUDP = *statsdListenAddress
}
if *statsdListenUDP == "" && *statsdListenTCP == "" { if *statsdListenUDP == "" && *statsdListenTCP == "" {
log.Fatalln("At least one of UDP/TCP listeners must be specified.") log.Fatalln("At least one of UDP/TCP listeners must be specified.")
@ -153,7 +142,7 @@ func main() {
log.Infof("Accepting StatsD Traffic: UDP %v, TCP %v", *statsdListenUDP, *statsdListenTCP) log.Infof("Accepting StatsD Traffic: UDP %v, TCP %v", *statsdListenUDP, *statsdListenTCP)
log.Infoln("Accepting Prometheus Requests on", *listenAddress) log.Infoln("Accepting Prometheus Requests on", *listenAddress)
go serveHTTP() go serveHTTP(*listenAddress, *metricsEndpoint)
events := make(chan Events, 1024) events := make(chan Events, 1024)
defer close(events) defer close(events)