Sha256: db7c2e88d305e2feb53b6e9d47c21b0e59a5a664cc5cc8870b2588aebbc4de01
Contents?: true
Size: 882 Bytes
Versions: 6
Compression:
Stored size: 882 Bytes
Contents
require 'fluent/test' class ObjectSpaceInputTest < Test::Unit::TestCase class FailObject def self.class raise "error" end end def setup Fluent::Test.setup end TESTCONFIG = %[ emit_interval 1 tag t1 top 2 ] def create_driver(conf=TESTCONFIG) Fluent::Test::InputTestDriver.new(Fluent::ObjectSpaceInput).configure(conf) end def test_configure d = create_driver assert_equal 1, d.instance.emit_interval assert_equal "t1", d.instance.tag assert_equal 2, d.instance.top end def test_emit d = create_driver time = Time.parse("2011-01-02 13:14:15").to_i d.expected_emits_length = 2 d.run emits = d.emits assert_equal true, emits.length > 0 emits.each { |tag, time, record| assert_equal d.instance.tag, tag assert_equal d.instance.top, record.keys.size } end end
Version data entries
6 entries across 6 versions & 1 rubygems