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