Sha256: dec42b5c72d5509794135bb80938440db1e1d338d777f7e011402dee1f19164b
Contents?: true
Size: 911 Bytes
Versions: 47
Compression:
Stored size: 911 Bytes
Contents
require_relative '../helper'
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
47 entries across 47 versions & 2 rubygems