module Fluent::Logplex

Constants

FACILITY_MAP
PRIORITY_MAP
SYSLOG_HTTP_REGEXP
SYSLOG_REGEXP

Public Instance Methods

parse_logplex(record, params=nil) click to toggle source
# File lib/fluent/plugin/logplex.rb, line 44
def parse_logplex(record, params=nil)
  pri = record['pri'].to_i
  record['facility'] = FACILITY_MAP[pri >> 3]
  record['priority'] = PRIORITY_MAP[pri & 0b111]

  if params
    record['drain_id'] = params['HTTP_LOGPLEX_DRAIN_TOKEN']
  end

  record
end