-
Notifications
You must be signed in to change notification settings - Fork 171
/
clickhouse_exporter.go
57 lines (48 loc) · 1.75 KB
/
clickhouse_exporter.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
package main
import (
"flag"
"net/http"
"net/url"
"os"
"github.com/ClickHouse/clickhouse_exporter/exporter"
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promhttp"
"github.com/rs/zerolog/log"
)
var (
listeningAddress = flag.String("telemetry.address", ":9116", "Address on which to expose metrics.")
metricsEndpoint = flag.String("telemetry.endpoint", "/metrics", "Path under which to expose metrics.")
clickhouseScrapeURI = flag.String("scrape_uri", "http://localhost:8123/", "URI to clickhouse http endpoint")
clickhouseOnly = flag.Bool("clickhouse_only", false, "Expose only Clickhouse metrics, not metrics from the exporter itself")
insecure = flag.Bool("insecure", true, "Ignore server certificate if using https")
user = os.Getenv("CLICKHOUSE_USER")
password = os.Getenv("CLICKHOUSE_PASSWORD")
)
func main() {
flag.Parse()
uri, err := url.Parse(*clickhouseScrapeURI)
if err != nil {
log.Fatal().Err(err).Send()
}
log.Printf("Scraping %s", *clickhouseScrapeURI)
registerer := prometheus.DefaultRegisterer
gatherer := prometheus.DefaultGatherer
if *clickhouseOnly {
reg := prometheus.NewRegistry()
registerer = reg
gatherer = reg
}
e := exporter.NewExporter(*uri, *insecure, user, password)
registerer.MustRegister(e)
http.Handle(*metricsEndpoint, promhttp.HandlerFor(gatherer, promhttp.HandlerOpts{}))
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
w.Write([]byte(`<html>
<head><title>Clickhouse Exporter</title></head>
<body>
<h1>Clickhouse Exporter</h1>
<p><a href="` + *metricsEndpoint + `">Metrics</a></p>
</body>
</html>`))
})
log.Fatal().Err(http.ListenAndServe(*listeningAddress, nil)).Send()
}