mirror
/
client_golang
mirror of https://github.com/prometheus/client_golang.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

Histogram with zero-width zero bucket 

Signed-off-by: beorn7 <beorn@grafana.com>
This commit is contained in:
beorn7 2024-06-20 19:03:14 +02:00
parent 14259fa70c
commit 9c344085f9
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
examples/random/main.go
View File

@ -60,10 +60,11 @@ func NewMetrics(reg prometheus.Registerer, normMean, normDomain float64) *metric
// one bucket to the next of (at most) 1.1. (The precise factor // one bucket to the next of (at most) 1.1. (The precise factor
// is 2^2^-3 = 1.0905077...) // is 2^2^-3 = 1.0905077...)
rpcDurationsHistogram: prometheus.NewHistogram(prometheus.HistogramOpts{ rpcDurationsHistogram: prometheus.NewHistogram(prometheus.HistogramOpts{
Name: "rpc_durations_histogram_seconds", Name: "rpc_durations_histogram_seconds",
Help: "RPC latency distributions.", Help: "RPC latency distributions.",
Buckets: prometheus.LinearBuckets(normMean-5*normDomain, .5*normDomain, 20), Buckets: prometheus.LinearBuckets(normMean-5*normDomain, .5*normDomain, 20),
NativeHistogramBucketFactor: 1.1, NativeHistogramBucketFactor: 1.1,
NativeHistogramZeroThreshold: prometheus.NativeHistogramZeroThresholdZero,
}), }),
} }
reg.MustRegister(m.rpcDurations) reg.MustRegister(m.rpcDurations)
@ -106,6 +107,18 @@ func main() {
}() }()
go func() { go func() {
m.rpcDurationsHistogram.(prometheus.ExemplarObserver).ObserveWithExemplar(
0, prometheus.Labels{"dummyID": fmt.Sprint(rand.Intn(100000))},
)
m.rpcDurationsHistogram.(prometheus.ExemplarObserver).ObserveWithExemplar(
0, prometheus.Labels{"dummyID": fmt.Sprint(rand.Intn(100000))},
)
m.rpcDurationsHistogram.(prometheus.ExemplarObserver).ObserveWithExemplar(
0, prometheus.Labels{"dummyID": fmt.Sprint(rand.Intn(100000))},
)
m.rpcDurationsHistogram.(prometheus.ExemplarObserver).ObserveWithExemplar(
0.01, prometheus.Labels{"dummyID": fmt.Sprint(rand.Intn(100000))},
)
for { for {
v := (rand.NormFloat64() * *normDomain) + *normMean v := (rand.NormFloat64() * *normDomain) + *normMean
m.rpcDurations.WithLabelValues("normal").Observe(v) m.rpcDurations.WithLabelValues("normal").Observe(v)
@ -118,7 +131,7 @@ func main() {
m.rpcDurationsHistogram.(prometheus.ExemplarObserver).ObserveWithExemplar( m.rpcDurationsHistogram.(prometheus.ExemplarObserver).ObserveWithExemplar(
v, prometheus.Labels{"dummyID": fmt.Sprint(rand.Intn(100000))}, v, prometheus.Labels{"dummyID": fmt.Sprint(rand.Intn(100000))},
) )
time.Sleep(time.Duration(75*oscillationFactor()) * time.Millisecond) time.Sleep(time.Duration(oscillationFactor()) * time.Millisecond)
} }
}() }()