Skip to content
This repository was archived by the owner on Aug 17, 2023. It is now read-only.

Commit a01c455

Browse files
author
Jonathan Chauncey
committed
feat(deis_out): Add time to record when publishing to nsq
1 parent af15873 commit a01c455

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

  • rootfs/opt/fluentd/deis-output/lib/fluent/plugin

rootfs/opt/fluentd/deis-output/lib/fluent/plugin/out_deis.rb

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@ def emit(tag, es, chain)
4242
es.each do |time, record|
4343
if from_controller?(record) || deis_deployed_app?(record)
4444
@logger_nsq ||= get_nsq_producer(@log_topic)
45+
record["time"] = Time.now().strftime("%FT%T.%6N%:z")
4546
push(@logger_nsq, record) if @logger_nsq
4647
end
4748

0 commit comments

Comments
 (0)