Skip to content


Codecs are used to describe how to decode data from the wire and encode it back to wire format.

Supported Codecs


En- and decodes JSON, for encoding a minified format is used (excluding newlines and spaces).


Treats the event as non structured string. It is required that the input is valid utf8 or the decoding will fail.


Msgpack works based on the msgpack binary format that is structurally compatible with JSON.

Being a binary format, message pack is significantly more performant and requires less space compared to JSON.

It is an excellent candidate to use in tremor to tremor deployments but as well with any offramp that does support this format.


En- and decodes the influx line protocol. The structural representation of the data is as follows:

weather,location=us-midwest temperature=82 1465839830100400200

translates to:

  "measurement": "weather",
  "tags": { "location": "us-midwest" },
  "fields": { "temperature": 82.0 },
  "timestamp": 1465839830100400200


The Binflux codec is a binary representation of influx data that is significantly faster encodes and decodes as well as takes less space on the wire.

The format itself does not include framing but can be used with the size-prefix pre/post processors.

For all numbers netwokr byte order is used (big endian). The data is represented as follows:

  1. 2 byte (u16) length of the measurement in bytes
  2. n byte (utf8) the measurement (utf8 encoded string)
  3. 8 byte (u64) the timestamp
  4. 2 byte (u16) number of tags (key value pairs) repetitions of:
  5. 2 byte (u16) lenght of the tag name in bytes
  6. n byte (utf8) tag name (utf8 encoded string)
  7. 2 byte (u16) lenght of tag value in bytes
  8. n byte (utf8) tag value (utf8 encoded string)
  9. 2 byte (u16) number of fiends (key value pairs) repetition of:
  10. 2 byte (u16) lenght of the tag name in bytes
  11. n byte (utf8) tag name (utf8 encoded string)
  12. 1 byte (tag) type of the field value can be one of:
  13. TYPE_I64 = 0 followed by 8 byte (i64)
    1. TYPE_F64 = 1 followed by 8 byte (f64)
    2. TYPE_TRUE = 2 no following data
    3. TYPE_FALSE = 3 no following data
    4. TYPE_STRING = 4 followed by 2 byte (u16) length of the string in bytes and n byte string value (utf8 encoded string)


The same as the influx, the statsd codec translates a single statsd measurement into a structured format. The structure is as follows:


Translates to:

  "type": "c",
  "metric": "sam",
  "value": 7,
  "sample_rate": 0.1

The following types are supported:

  • c for counter
  • ms for timing
  • g for gauge
  • h for histogram
  • s for sets

For gauge there is also the field action which might be add if the value was prefixed with a +, or sub if the value was prefixed with a -


En- and decodes YAML.