class LogStash::Codecs::Bytes
Public Instance Methods
decode(data) { |event({ "message" => line })| ... }
click to toggle source
# File lib/logstash/codecs/bytes.rb, line 29 def decode(data) @payload += data.bytes.to_a while @payload.length >= @length line = @payload.slice!(0...@length).pack('c*') yield LogStash::Event.new({ "message" => line }) end end
register()
click to toggle source
# File lib/logstash/codecs/bytes.rb, line 24 def register @payload = [] end