class Fluent::Plugin::FormatterSyslogRFC5424

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/formatter_syslog_rfc5424.rb, line 16
def configure(conf)
  super
  @hostname_field_array = @hostname_field.split(".")
  @app_name_field_array = @app_name_field.split(".")
  @proc_id_field_array = @proc_id_field.split(".")
  @message_id_field_array = @message_id_field.split(".")
  @structured_data_field_array = @structured_data_field.split(".")
  @log_field_array = @log_field.split(".")
end
format(tag, time, record) click to toggle source
# File lib/fluent/plugin/formatter_syslog_rfc5424.rb, line 26
def format(tag, time, record)
  log.debug("Record")
  log.debug(record.map { |k, v| "#{k}=#{v}" }.join('&'))

  msg = RFC5424::Formatter.format(
    log: record.dig(*@log_field_array) || "-",
    timestamp: time,
    hostname: record.dig(*@hostname_field_array) || "-",
    app_name: record.dig(*@app_name_field_array) || "-",
    proc_id: record.dig(*@proc_id_field_array) || "-",
    msg_id: record.dig(*@message_id_field_array) || "-",
    sd: record.dig(*@structured_data_field_array) || "-"
  )

  log.debug("RFC 5424 Message")
  log.debug(msg)

  return msg + "\n" unless @rfc6587_message_size

  msg.length.to_s + ' ' + msg
end