onyx.metrics.riemann — org.onyxplatform/onyx-metrics 0.13.0.1-SNAPSHOT

max-backoff-time clj

metric->riemann-event clj

(metric->riemann-event metric)

next-sleep-time clj

(next-sleep-time current)

read-batch clj

(read-batch ch batch-size batch-timeout)

riemann-sender clj

(riemann-sender {:keys [riemann/address riemann/port riemann/batch-size
                        riemann/batch-timeout riemann/send-timeout]
                 :as riemann-config}
                ch
                shutdown?)