Merge pull request #606 from kawanet/fluent-cat-format-none

fluent-cat --format none added

lib/fluent/command/cat.rb

@@ -28,6 +28,7 @@
 
 config_path = Fluent::DEFAULT_CONFIG_PATH
 format = 'json'
+message_key = 'message'
 
 op.on('-p', '--port PORT', "fluent tcp port (default: #{port})", Integer) {|i|
   port = i
@@ -57,6 +58,14 @@
   format = 'msgpack'
 }
 
+op.on('--none', "same as: -f none", TrueClass) {|b|
+  format = 'none'
+}
+
+op.on('--message-key KEY', "key field for none format (default: #{message_key})") {|s|
+  message_key = s
+}
+
 (class<<self;self;end).module_eval do
   define_method(:usage) do |msg|
     puts op.to_s
@@ -290,6 +299,17 @@ def abort_message(time, record)
     exit 1
   end
 
+when 'none'
+  begin
+    while line = $stdin.gets
+      record = { message_key => line.chomp }
+      w.write(record)
+    end
+  rescue
+    $stderr.puts $!
+    exit 1
+  end
+
 else
   $stderr.puts "Unknown format '#{format}'"
   exit 1