Example logomotive configuration file

configuration.clj

(ns configuration
  (:require [logomotive.api.input :as input]
            [logomotive.api.output :as output]
            [logomotive.api.transform :as transform]
            ))

; Read events from stdin, keep it as-is
(input/stdin {:format :plain})

; Read events from UDP on port 1984, keep it as-is
(input/udp {:port 1984})

; Read events sent by collectd, implicitly assuming that structure is of collectd (Binary protocol)
; This input listens on UDP port 25826
(input/collectd {:port 25826})


; Into all events, add tag :logomotive
(transform/tag {:condition-fn (constantly true)
                :add [:logomotive]})


; Print all events on stdout
(output/stdout {})

; Print all events to file, one json document per line. Only events received from input of type :udp
(output/file {:path "/tmp/example.log"
              :structure :jsonline
              :condition-fn (fn [event] (= :udp (:type-in event)))})