Provide a way to change Riemann default info

This commit is contained in:
Yann Esposito 2015-02-17 15:16:36 +01:00
parent 596b42a124
commit 92a6a41d5b
2 changed files with 9 additions and 4 deletions

View file

@ -33,7 +33,8 @@ Full example:
}
nb-ms-metrics
riemann-host
riemann-service)
riemann-service
{:host "My-Custom-Name"})
;; If you log metrics not declared in init-metrics, they will show as always "ok"

View file

@ -15,6 +15,7 @@
;; Atoms
(def pool (atom nil)) ;; pool for async
(def default-map (atom #{}))
(def riemann-default (atom nil))
(def riemann-conn (atom nil))
(def riemann-service (atom "supercell"))
(def level-by-key (atom nil))
@ -72,8 +73,10 @@
(defn send-to-riemann [m]
(let [result-map (into @default-map m)
metric-data {:service @riemann-service
metric-data (into
{:service @riemann-service
:state "ok"}
@riemann-default)
events (remove nil? (map to-riemann-event result-map))
]
(when @riemann-conn
@ -114,12 +117,13 @@
"## init-metrics
init-map :: Map Keyword (v -> ERROR_LEVEL)"
[init-map nb-ms-metrics riemann-host riemann-service-name]
[init-map nb-ms-metrics riemann-host riemann-service-name riemann-default]
(reset! default-map (reduce into {}
(map (fn [k] {k -1} )
(conj (keys init-map) :total))))
(reset! level-by-key init-map)
(reset! pool (mk-pool))
(reset! riemann-conf riemann-default)
(reset! riemann-service riemann-service-name)
(when riemann-host
(reset! riemann-conn (r/tcp-client {:host riemann-host})))