class LogStash::Codecs::Plain

The “plain” codec is for plain text with no delimiting between events.

This is mainly useful on inputs and outputs that already have a defined framing in their transport protocol (such as zeromq, rabbitmq, redis, etc)

Public Instance Methods

decode(data) { |event("message" => convert)| ... } click to toggle source
# File lib/logstash/codecs/plain.rb, line 35
def decode(data)
  yield LogStash::Event.new("message" => @converter.convert(data))
end
encode(data) click to toggle source
# File lib/logstash/codecs/plain.rb, line 40
def encode(data)
  if data.is_a? LogStash::Event and @format
    @on_event.call(data.sprintf(@format))
  else
    @on_event.call(data.to_s)
  end
end
register() click to toggle source
# File lib/logstash/codecs/plain.rb, line 29
def register
  @converter = LogStash::Util::Charset.new(@charset)
  @converter.logger = @logger
end