Class: LogStash::Codecs::GoogleAppengine

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/codecs/google_appengine.rb

Instance Method Summary collapse

Instance Method Details

#decode(data) ⇒ Object 



16
17
18
19
20
21
22
23
24
25
 
# File 'lib/logstash/codecs/google_appengine.rb', line 16

def decode(data)
  begin
    data = LogStash::Json.load(data)
    flatten(data).each { |flattenedJson|
      yield(LogStash::Event.new(flattenedJson))
    }
  rescue => e
    @logger.error "Failed to process data", :error => e, :data => data
  end
end

#register ⇒ Object 



12
13
14
 
# File 'lib/logstash/codecs/google_appengine.rb', line 12

def register
  @md5 = Digest::MD5.new
end