lib/fluent/plugin/in_redis_slowlog.rb in gitlab-fluent-plugin-redis-slowlog-0.0.1 vs lib/fluent/plugin/in_redis_slowlog.rb in gitlab-fluent-plugin-redis-slowlog-0.0.2
- old
+ new
@@ -80,10 +80,10 @@
slowlogs.reverse_each do |log|
# Don't emit logs for entries we've already logged
next if log.first <= current_log_id
log_hash = { "id" => log[0],
- "timestamp" => Time.at(log[1]),
+ "timestamp" => log[1].to_i,
"exec_time" => log[2],
"command" => log[3] }
router.emit(tag, Time.now.to_i, log_hash)
end
end