resetting_timer_test.go 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. package metrics
  2. import (
  3. "testing"
  4. "time"
  5. )
  6. func TestResettingTimer(t *testing.T) {
  7. tests := []struct {
  8. values []int64
  9. start int
  10. end int
  11. wantP50 int64
  12. wantP95 int64
  13. wantP99 int64
  14. wantMean float64
  15. wantMin int64
  16. wantMax int64
  17. }{
  18. {
  19. values: []int64{},
  20. start: 1,
  21. end: 11,
  22. wantP50: 5, wantP95: 10, wantP99: 10,
  23. wantMin: 1, wantMax: 10, wantMean: 5.5,
  24. },
  25. {
  26. values: []int64{},
  27. start: 1,
  28. end: 101,
  29. wantP50: 50, wantP95: 95, wantP99: 99,
  30. wantMin: 1, wantMax: 100, wantMean: 50.5,
  31. },
  32. {
  33. values: []int64{1},
  34. start: 0,
  35. end: 0,
  36. wantP50: 1, wantP95: 1, wantP99: 1,
  37. wantMin: 1, wantMax: 1, wantMean: 1,
  38. },
  39. {
  40. values: []int64{0},
  41. start: 0,
  42. end: 0,
  43. wantP50: 0, wantP95: 0, wantP99: 0,
  44. wantMin: 0, wantMax: 0, wantMean: 0,
  45. },
  46. {
  47. values: []int64{},
  48. start: 0,
  49. end: 0,
  50. wantP50: 0, wantP95: 0, wantP99: 0,
  51. wantMin: 0, wantMax: 0, wantMean: 0,
  52. },
  53. {
  54. values: []int64{1, 10},
  55. start: 0,
  56. end: 0,
  57. wantP50: 1, wantP95: 10, wantP99: 10,
  58. wantMin: 1, wantMax: 10, wantMean: 5.5,
  59. },
  60. }
  61. for ind, tt := range tests {
  62. timer := NewResettingTimer()
  63. for i := tt.start; i < tt.end; i++ {
  64. tt.values = append(tt.values, int64(i))
  65. }
  66. for _, v := range tt.values {
  67. timer.Update(time.Duration(v))
  68. }
  69. snap := timer.Snapshot()
  70. ps := snap.Percentiles([]float64{50, 95, 99})
  71. val := snap.Values()
  72. if len(val) > 0 {
  73. if tt.wantMin != val[0] {
  74. t.Fatalf("%d: min: got %d, want %d", ind, val[0], tt.wantMin)
  75. }
  76. if tt.wantMax != val[len(val)-1] {
  77. t.Fatalf("%d: max: got %d, want %d", ind, val[len(val)-1], tt.wantMax)
  78. }
  79. }
  80. if tt.wantMean != snap.Mean() {
  81. t.Fatalf("%d: mean: got %.2f, want %.2f", ind, snap.Mean(), tt.wantMean)
  82. }
  83. if tt.wantP50 != ps[0] {
  84. t.Fatalf("%d: p50: got %d, want %d", ind, ps[0], tt.wantP50)
  85. }
  86. if tt.wantP95 != ps[1] {
  87. t.Fatalf("%d: p95: got %d, want %d", ind, ps[1], tt.wantP95)
  88. }
  89. if tt.wantP99 != ps[2] {
  90. t.Fatalf("%d: p99: got %d, want %d", ind, ps[2], tt.wantP99)
  91. }
  92. }
  93. }