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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
(ns puppetlabs.metrics-test
(:import (com.codahale.metrics MetricRegistry Meter Timer)
(java.util.concurrent TimeUnit))
(:require [clojure.test :refer :all]
[puppetlabs.metrics :refer :all]
[schema.test :as schema-test]))
(use-fixtures :once schema-test/validate-schemas)
(deftest test-host-metric-name
(testing "host-metric-name should create a metric name"
(is (= "puppetlabs.localhost.foocount" (host-metric-name "localhost" "foocount")))))
(deftest test-http-metric-name
(testing "http-metric-name should create a metric name"
(is (= "puppetlabs.localhost.http.foocount" (http-metric-name "localhost" "foocount")))))
(deftest test-register
(testing "register should add a metric to the registry"
(let [registry (MetricRegistry.)]
(register registry (host-metric-name "localhost" "foo") (gauge 2))
(let [gauges (.getGauges registry)]
(is (= 1 (count gauges)))
(is (= "puppetlabs.localhost.foo" (first (.keySet gauges))))))))
(deftest test-mean-utils
(let [timer (Timer.)]
(time! timer
(Thread/sleep 1))
(is (= 1 (.getCount timer)))
(let [elapsed-nanos (mean timer)
elapsed-millis (mean-millis timer)
elapsed-in-millis (mean-in-unit timer TimeUnit/MILLISECONDS)
elapsed-in-nanos (mean-in-unit timer TimeUnit/NANOSECONDS)]
(is (>= elapsed-millis 1))
(is (>= elapsed-in-millis 1))
(is (<= elapsed-millis 100))
(is (<= elapsed-in-millis 100))
(is (>= elapsed-nanos (* 1000 1000)))
(is (>= elapsed-in-nanos (* 1000 1000)))
(is (<= elapsed-nanos (* 1000 1000 100)))
(is (<= elapsed-in-nanos (* 1000 1000 100))))))
(deftest test-ratio
(testing "ratio should create a ratio metric"
(let [numerator (atom 4)
numerator-fn (fn [] @numerator)
denominator-fn (constantly 2)
ratio-metric (ratio numerator-fn denominator-fn)]
(is (= 2.0 (.. ratio-metric getRatio getValue)))
(reset! numerator 6)
(is (= 3.0 (.. ratio-metric getRatio getValue))))))
(deftest test-metered-ratio
(testing "metered-ratio builds a ratio metric from two counters"
(let [numerator-meter (Meter.)
denominator-timer (Timer.)
ratio-metric (metered-ratio numerator-meter denominator-timer)]
(dotimes [_ 2] (.update denominator-timer 0 TimeUnit/MILLISECONDS))
(dotimes [_ 4] (.mark numerator-meter))
(is (= 2.0 (.. ratio-metric getRatio getValue)))
(dotimes [_ 2] (.mark numerator-meter))
(is (= 3.0 (.. ratio-metric getRatio getValue))))))
(deftest test-gauge
(testing "gauge creates a gauge metric with an initial value"
(let [gauge-metric (gauge 42)]
(is (= 42 (.getValue gauge-metric))))))
(deftest test-time!
(testing "time! will time the enclosed form"
(let [timer (Timer.)]
(time! timer
(Thread/sleep 1))
(is (= 1 (.getCount timer)))
(let [elapsed (mean-millis timer)]
(is (>= elapsed 1))
(is (<= elapsed 100))))))
|
