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.