mirrors/statsd_exporter
1
0
Fork 1
mirror of https://github.com/prometheus/statsd_exporter.git synced 2025-03-13 11:12:39 +00:00
Code Issues Projects Releases Packages Wiki Activity

Add basic TLS listener support

Browse source 
Signed-off-by: Tom Noonan II <tom@tjnii.com>
This commit is contained in:
Tom Noonan II 2025-01-29 16:47:09 -05:00
parent a7bc1e8652
commit b780dbb081
1 changed files with 12 additions and 4 deletions

14
main.go
View file

@ -173,8 +173,15 @@ var (
)
)
func serveHTTP(mux http.Handler, listenAddress string, logger *slog.Logger) {
func serveHTTP(mux http.Handler, listenAddress string, listenTLSCert string, listenTLSKey string, logger *slog.Logger) {
if listenTLSCert == "" && listenTLSKey == "" {
logger.Info("Accepting Prometheus Requests over HTTP", "addr", listenAddress)
logger.Error(http.ListenAndServe(listenAddress, mux).Error())
} else {
logger.Info("Accepting Prometheus Requests over HTTPS", "addr", listenAddress)
logger.Error(http.ListenAndServeTLS(listenAddress, listenTLSCert, listenTLSKey, mux).Error())
}
os.Exit(1)
}
@ -245,6 +252,8 @@ func getCache(cacheSize int, cacheType string, registerer prometheus.Registerer)
func main() {
var (
listenAddress = kingpin.Flag("web.listen-address", "The address on which to expose the web interface and generated Prometheus metrics.").Default(":9102").String()
listenTLSCert = kingpin.Flag("web.listen-tls-cert", "TLS certificate filename for the web interface. Enables TLS when set. \"\" disables TLS").Default("").String()
listenTLSKey = kingpin.Flag("web.listen-tls-key", "TLS key filename for the web interface. Enables TLS when set. \"\" disables TLS").Default("").String()
enableLifecycle = kingpin.Flag("web.enable-lifecycle", "Enable shutdown and reload via HTTP request.").Default("false").Bool()
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()
@ -344,7 +353,6 @@ func main() {
}
logger.Info("Accepting StatsD Traffic", "udp", *statsdListenUDP, "tcp", *statsdListenTCP, "unixgram", *statsdListenUnixgram)
logger.Info("Accepting Prometheus Requests", "addr", *listenAddress)
if *statsdListenUDP == "" && *statsdListenTCP == "" && *statsdListenUnixgram == "" {
logger.Error("At least one of UDP/TCP/Unixgram listeners must be specified.")
@ -546,7 +554,7 @@ func main() {
}
})
go serveHTTP(mux, *listenAddress, logger)
go serveHTTP(mux, *listenAddress, *listenTLSCert, *listenTLSKey, logger)
go sighupConfigReloader(*mappingConfig, thisMapper, logger)
go exporter.Listen(events)