class Fluent::TextParser::SentryHttpParser

Public Class Methods

new() click to toggle source
Calls superclass method
# File lib/fluent/plugin/parser_sentry_http.rb, line 13
def initialize
  super
end

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/parser_sentry_http.rb, line 17
def configure(conf)
  super
end
parse(text) { |time, record| ... } click to toggle source
# File lib/fluent/plugin/parser_sentry_http.rb, line 21
def parse(text)
  message = Zlib::Inflate.inflate(Base64.decode64(text))
  record = Oj.load(message, :mode => :compat)

  record_time = record['timestamp']
  time = record_time.nil? ? Engine.now : Time.parse(record_time).to_i

  record = {@field_name => message} unless @json_parse

  yield time, record
rescue => e
  $log.warn "parse error: #{e.message}"
  yield nil, nil
end