timer_test.go 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114
  1. package metrics
  2. import (
  3. "fmt"
  4. "math"
  5. "testing"
  6. "time"
  7. )
  8. func BenchmarkTimer(b *testing.B) {
  9. tm := NewTimer()
  10. b.ResetTimer()
  11. for i := 0; i < b.N; i++ {
  12. tm.Update(1)
  13. }
  14. }
  15. func TestGetOrRegisterTimer(t *testing.T) {
  16. r := NewRegistry()
  17. NewRegisteredTimer("foo", r).Update(47)
  18. if tm := GetOrRegisterTimer("foo", r); tm.Count() != 1 {
  19. t.Fatal(tm)
  20. }
  21. }
  22. func TestTimerExtremes(t *testing.T) {
  23. tm := NewTimer()
  24. tm.Update(math.MaxInt64)
  25. tm.Update(0)
  26. if stdDev := tm.StdDev(); stdDev != 4.611686018427388e+18 {
  27. t.Errorf("tm.StdDev(): 4.611686018427388e+18 != %v\n", stdDev)
  28. }
  29. }
  30. func TestTimerStop(t *testing.T) {
  31. l := len(arbiter.meters)
  32. tm := NewTimer()
  33. if l+1 != len(arbiter.meters) {
  34. t.Errorf("arbiter.meters: %d != %d\n", l+1, len(arbiter.meters))
  35. }
  36. tm.Stop()
  37. if l != len(arbiter.meters) {
  38. t.Errorf("arbiter.meters: %d != %d\n", l, len(arbiter.meters))
  39. }
  40. }
  41. func TestTimerFunc(t *testing.T) {
  42. var (
  43. tm = NewTimer()
  44. testStart = time.Now()
  45. actualTime time.Duration
  46. )
  47. tm.Time(func() {
  48. time.Sleep(50 * time.Millisecond)
  49. actualTime = time.Since(testStart)
  50. })
  51. var (
  52. drift = time.Millisecond * 2
  53. measured = time.Duration(tm.Max())
  54. ceil = actualTime + drift
  55. floor = actualTime - drift
  56. )
  57. if measured > ceil || measured < floor {
  58. t.Errorf("tm.Max(): %v > %v || %v > %v\n", measured, ceil, measured, floor)
  59. }
  60. }
  61. func TestTimerZero(t *testing.T) {
  62. tm := NewTimer()
  63. if count := tm.Count(); count != 0 {
  64. t.Errorf("tm.Count(): 0 != %v\n", count)
  65. }
  66. if min := tm.Min(); min != 0 {
  67. t.Errorf("tm.Min(): 0 != %v\n", min)
  68. }
  69. if max := tm.Max(); max != 0 {
  70. t.Errorf("tm.Max(): 0 != %v\n", max)
  71. }
  72. if mean := tm.Mean(); mean != 0.0 {
  73. t.Errorf("tm.Mean(): 0.0 != %v\n", mean)
  74. }
  75. if stdDev := tm.StdDev(); stdDev != 0.0 {
  76. t.Errorf("tm.StdDev(): 0.0 != %v\n", stdDev)
  77. }
  78. ps := tm.Percentiles([]float64{0.5, 0.75, 0.99})
  79. if ps[0] != 0.0 {
  80. t.Errorf("median: 0.0 != %v\n", ps[0])
  81. }
  82. if ps[1] != 0.0 {
  83. t.Errorf("75th percentile: 0.0 != %v\n", ps[1])
  84. }
  85. if ps[2] != 0.0 {
  86. t.Errorf("99th percentile: 0.0 != %v\n", ps[2])
  87. }
  88. if rate1 := tm.Rate1(); rate1 != 0.0 {
  89. t.Errorf("tm.Rate1(): 0.0 != %v\n", rate1)
  90. }
  91. if rate5 := tm.Rate5(); rate5 != 0.0 {
  92. t.Errorf("tm.Rate5(): 0.0 != %v\n", rate5)
  93. }
  94. if rate15 := tm.Rate15(); rate15 != 0.0 {
  95. t.Errorf("tm.Rate15(): 0.0 != %v\n", rate15)
  96. }
  97. if rateMean := tm.RateMean(); rateMean != 0.0 {
  98. t.Errorf("tm.RateMean(): 0.0 != %v\n", rateMean)
  99. }
  100. }
  101. func ExampleGetOrRegisterTimer() {
  102. m := "account.create.latency"
  103. t := GetOrRegisterTimer(m, nil)
  104. t.Update(47)
  105. fmt.Println(t.Max()) // Output: 47
  106. }