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