require 'json' require 'time' require 'date' module LogStasher class Event def initialize(data = {}) @cancelled = false @data = data if data.include?('@timestamp') t = data['@timestamp'] data['@timestamp'] = Time.parse(t).gmtime.iso8601(3) if t.is_a?(String) else data['@timestamp'] = ::Time.now.utc.iso8601(3) end data['@version'] = '1' unless @data.include?('@version') end def to_s to_json.to_s end def to_json(*args) @data.to_json(*args) end def [](key) @data[key] end end end