Sha256: 12381faea9f036928db7ff17ec722bf8a7436101b2dc1df816b2178e2aaedf2e
Contents?: true
Size: 1.58 KB
Versions: 135
Compression:
Stored size: 1.58 KB
Contents
require_relative '../helper'
require 'fluent/test/driver/formatter'
require 'fluent/plugin/formatter_tsv'
class TSVFormatterTest < ::Test::Unit::TestCase
def setup
@time = event_time
end
def create_driver(conf = "")
Fluent::Test::Driver::Formatter.new(Fluent::Plugin::TSVFormatter).configure(conf)
end
def tag
"tag"
end
def record
{'message' => 'awesome', 'greeting' => 'hello'}
end
def test_config_params
d = create_driver(
'keys' => 'message,greeting',
)
assert_equal ["message", "greeting"], d.instance.keys
assert_equal "\t", d.instance.delimiter
assert_equal true, d.instance.add_newline
d = create_driver(
'keys' => 'message,greeting',
'delimiter' => ',',
'add_newline' => false,
)
assert_equal ["message", "greeting"], d.instance.keys
assert_equal ",", d.instance.delimiter
assert_equal false, d.instance.add_newline
end
def test_format
d = create_driver(
'keys' => 'message,greeting',
)
formatted = d.instance.format(tag, @time, record)
assert_equal("awesome\thello\n", formatted)
end
def test_format_without_newline
d = create_driver(
'keys' => 'message,greeting',
'add_newline' => false,
)
formatted = d.instance.format(tag, @time, record)
assert_equal("awesome\thello", formatted)
end
def test_format_with_customized_delimiters
d = create_driver(
'keys' => 'message,greeting',
'delimiter' => ',',
)
formatted = d.instance.format(tag, @time, record)
assert_equal("awesome,hello\n", formatted)
end
end
Version data entries
135 entries across 135 versions & 1 rubygems