riemann.transport.opentsdb
decode-opentsdb-line
(decode-opentsdb-line line)
Parse an OpenTSDB message string into an event.
initializer
(initializer parser-fn message-handler)
The pipeline of decoders, handlers, etc for parsing and handling messages.
opentsdb-frame-decoder
(opentsdb-frame-decoder parser-fn)
A MessageToMessageDecoder that reads strings and emits either :version or events.
opentsdb-handler
(opentsdb-handler core stats ctx message)
Messages to this handler are either :version or an event. Responds to version requests, and applies events to the core.
opentsdb-server
(opentsdb-server)
(opentsdb-server opts)
Start a opentsdb-server. Options:
- :host “127.0.0.1”
- :port 4242
- :parser-fn an optional function which transforms events prior to streaming into the core.