Sha256: 346499d97c442319e0fdd624fc2ac5beea3e07442f17e6af5e0287aad9af8602
Contents?: true
Size: 1.38 KB
Versions: 20
Compression:
Stored size: 1.38 KB
Contents
require_relative '../helper'
require 'fluent/test/driver/formatter'
require 'fluent/plugin/formatter_ltsv'
class LabeledTSVFormatterTest < ::Test::Unit::TestCase
def setup
@time = event_time
end
def create_driver(conf = "")
Fluent::Test::Driver::Formatter.new(Fluent::Plugin::LabeledTSVFormatter).configure(conf)
end
def tag
"tag"
end
def record
{'message' => 'awesome', 'greeting' => 'hello'}
end
def test_config_params
d = create_driver
assert_equal "\t", d.instance.delimiter
assert_equal ":", d.instance.label_delimiter
d = create_driver(
'delimiter' => ',',
'label_delimiter' => '=',
)
assert_equal ",", d.instance.delimiter
assert_equal "=", d.instance.label_delimiter
end
def test_format
d = create_driver({})
formatted = d.instance.format(tag, @time, record)
assert_equal("message:awesome\tgreeting:hello\n", formatted)
end
def test_format_without_newline
d = create_driver('add_newline' => false)
formatted = d.instance.format(tag, @time, record)
assert_equal("message:awesome\tgreeting:hello", formatted)
end
def test_format_with_customized_delimiters
d = create_driver(
'delimiter' => ',',
'label_delimiter' => '=',
)
formatted = d.instance.format(tag, @time, record)
assert_equal("message=awesome,greeting=hello\n", formatted)
end
end
Version data entries
20 entries across 20 versions & 2 rubygems