test: Add test cases to verify interoperability for handling encupsulated timestamps

Signed-off-by: Hiroshi Hatake <hiroshi@chronosphere.io>

Author: cosmo0920

test/plugin/test_in_forward.rb

@@ -276,6 +276,25 @@ def create_driver(conf=base_config)
       assert_equal(records, d.events)
     end
 
+    test 'metadata attached logs type in entries array' do
+      @d = d = create_driver
+
+      time = event_time("2011-01-02 13:14:15 UTC")
+      metadata = {}
+
+      records = [
+        {"a"=>1},
+        {"a"=>2}
+      ]
+
+      d.run(expect_records: records.length, timeout: 20) do
+        entries = records.map { |record| [[time, metadata], record] }
+        send_data packer.write(["tag1", entries, {"fluent_signal" => 0}]).to_s
+      end
+      assert_equal(["tag1", "tag1"], d.events.map { |tag, _time, _record| tag })
+      assert_equal(records, d.events.map { |_tag, _time, record| record })
+    end
+
     data(tag: {
            param: "tag new_tag",
            result: "new_tag"
@@ -407,6 +426,28 @@ def create_driver(conf=base_config)
       assert_equal(records, d.events)
     end
 
+    test 'metadata attached logs type in packed entries' do
+      @d = d = create_driver
+
+      time = event_time("2011-01-02 13:14:15 UTC")
+      metadata = {}
+
+      records = [
+        {"a"=>1},
+        {"a"=>2},
+      ]
+
+      d.run(expect_records: records.length, timeout: 20) do
+        entries = ''
+        records.each {|record|
+          packer(entries).write([[time, metadata], record]).flush
+        }
+        send_data packer.write(["tag1", entries, {"fluent_signal" => 0}]).to_s
+      end
+      assert_equal(["tag1", "tag1"], d.events.map { |tag, _time, _record| tag })
+      assert_equal(records, d.events.map { |_tag, _time, record| record })
+    end
+
     data(tag: {
            param: "tag new_tag",
            result: "new_tag"