Class: LogStash::Codecs::Bytes

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/codecs/bytes.rb

Instance Method Summary collapse

Instance Method Details

#decode(data) ⇒ Object 



29
30
31
32
33
34
35
36
37
38
 
# 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 ⇒ Object 



24
25
26
 
# File 'lib/logstash/codecs/bytes.rb', line 24

def register
  @payload = []
end