class LogStash::Codecs::EDN

Public Instance Methods

decode(data) { |event(read)| ... } click to toggle source
# File lib/logstash/codecs/edn.rb, line 14
def decode(data)
  begin
    yield LogStash::Event.new(EDN.read(data))
  rescue
    @logger.info("EDN parse failure. Falling back to plain-text", :error => e, :data => data)
    yield LogStash::Event.new("message" => data)
  end
end
encode(data) click to toggle source
# File lib/logstash/codecs/edn.rb, line 24
def encode(data)
  @on_event.call(data.to_hash.to_edn)
end
register() click to toggle source
# File lib/logstash/codecs/edn.rb, line 9
def register
  require "edn"
end