22 lines
537 B
Clojure
22 lines
537 B
Clojure
; -*- mode: clojure; -*-
|
|
; vim: filetype=clojure
|
|
|
|
(logging/init {:file "/var/log/riemann/riemann.log"})
|
|
|
|
; Listen on the local interface over TCP (5555), UDP (5555), and websockets
|
|
; (5556)
|
|
(let [host "0.0.0.0"]
|
|
(tcp-server {:host host})
|
|
(udp-server {:host host})
|
|
(ws-server {:host host}))
|
|
|
|
; Expire old events from the index every 5 seconds.
|
|
(periodically-expire 5)
|
|
|
|
(let [index (index)]
|
|
(streams
|
|
(expired #(prn "Expired" %))
|
|
(where (not (service #"^riemann "))
|
|
index
|
|
#(info "received event" %))))
|