For use in an input plugin 'b' should be written into
pipeline.PipelinePack.MsgBytes and the pack should be sent to a ProtobufDecoder
(which will perform the de-serialization below)
Trink
- Original Message -
> From: "David Birdsong"
> To: "Michael Trinkala"
> Cc: "heka"
> Sent: F
Right. You can do the deserialization directly in the input, but if you
pass it on to a decoder (which will be running in its own separate
goroutine) that frees up the input to go back to the network to grab
the next record, keeping the pipeline full. Won't matter much when
maxprocs=1, but migh
2 matches
Mail list logo
