feat(tiller): add -prometheus-histograms flag

When Tiller is started with -prometheus-histograms flag, goprom.EnableHandlingTimeHistogram()
is used to enable RPC request latencies reporting via Prometheus historgrams.
pull/3036/head
Ilya Saulenko 8 years ago
parent b30be7a9d3
commit 427e1c76e1

@ -69,6 +69,7 @@ const (
var ( var (
grpcAddr = flag.String("listen", ":44134", "address:port to listen on") grpcAddr = flag.String("listen", ":44134", "address:port to listen on")
enableTracing = flag.Bool("trace", false, "enable rpc tracing") enableTracing = flag.Bool("trace", false, "enable rpc tracing")
enableHistograms = flag.Bool("prometheus-histograms", false, "enable reporting of RPC request latencies via prometheus histograms")
store = flag.String("storage", storageConfigMap, "storage driver to use. One of 'configmap', 'memory', or 'secret'") store = flag.String("storage", storageConfigMap, "storage driver to use. One of 'configmap', 'memory', or 'secret'")
remoteReleaseModules = flag.Bool("experimental-release", false, "enable experimental release modules") remoteReleaseModules = flag.Bool("experimental-release", false, "enable experimental release modules")
tlsEnable = flag.Bool("tls", tlsEnableEnvVarDefault(), "enable TLS") tlsEnable = flag.Bool("tls", tlsEnableEnvVarDefault(), "enable TLS")
@ -183,6 +184,12 @@ func start() {
// Register gRPC server to prometheus to initialized matrix // Register gRPC server to prometheus to initialized matrix
goprom.Register(rootServer) goprom.Register(rootServer)
if *enableHistograms {
goprom.EnableHandlingTimeHistogram()
logger.Println("Prometheus histograms reporting is enabled")
}
addPrometheusHandler(mux) addPrometheusHandler(mux)
if err := http.ListenAndServe(probeAddr, mux); err != nil { if err := http.ListenAndServe(probeAddr, mux); err != nil {

Loading…
Cancel
Save