Class: LogStash::Codecs::Fieldselect

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

Instance Method Summary collapse

Instance Method Details

#decode(data) ⇒ Object



31
32
33
34
35
36
37
38
# File 'lib/logstash/codecs/fieldselect.rb', line 31

def decode(data)
  @lines.decode(data) do |line|
    logger.debug? and @logger.debug("Running fieldselect codec", :data => data)
    selected = field_selector(line)
    logger.debug? and @logger.debug("Fieldselect codec ran", :selected => selected)
    yield LogStash::Event.new(selected)
  end
end

#encode(event) ⇒ Object



41
42
43
44
# File 'lib/logstash/codecs/fieldselect.rb', line 41

def encode(event)
  encoded = field_concater(event)
  @on_event.call(event, encoded)
end

#registerObject



25
26
27
28
# File 'lib/logstash/codecs/fieldselect.rb', line 25

def register
  @lines = LogStash::Codecs::Line.new
  @lines.charset = "UTF-8"
end