heka-decode-stream
v0.2.0
Published
Decode Heka's framing delimited protobufs into js objects
Downloads
3
Readme
heka-stream
Stream Heka's frame delimited protobuf messages
Example
var fs = require('fs')
var zlib = require('zlib')
var HekaStream = require('heka-stream')
fs.createReadStream(__dirname + '/data.gz')
.pipe(zlib.createGunzip())
.pipe(HekaStream.createDecodeStream())
.on('data', function (message) {
console.log(message.type)
console.log(message.fields)
})