Contents

require_relative 'helper'
require 'fluent/formatter'
require 'fluent/plugin/formatter_tsv'

class TsvFormatterTest < ::Test::Unit::TestCase
  def setup
    @formatter = Fluent::Plugin.new_formatter('tsv')
    @time = Fluent::Engine.now
  end

  def configure(conf)
    @formatter.configure({'utc' => true}.merge(conf))
  end

  def test_format
    configure({})
    tag = 'foo.test'
    record = {"a" => "foo", "b" => "bar"}

    formatted = @formatter.format(tag, @time, record)
    assert_equal("foo\tbar\n", formatted)
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-formatter_tsv-0.0.1	test/test_formatter_tsv.rb