Sha256: eada892c00ea883575d30a21ea5a74bbf25ffd49bebe14f7ace62177363c3f71

Contents?: true

Size: 726 Bytes

Versions: 10

Compression:

Stored size: 726 Bytes

Contents

require 'fluent/test'

class ObjectSpaceInputTest < Test::Unit::TestCase
  def setup
    Fluent::Test.setup
  end

  CONFIG = %[
    emit_interval 1
    tag t1
    top 2
  ]

  def create_driver(conf=CONFIG)
    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.run do
      sleep 2
    end

    emits = d.emits
    assert_equal true, emits.length > 0

    tag, time, record = emits[0]
    assert_equal 2, record.size
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
fluentd-0.10.25 test/plugin/in_object_space.rb
fluentd-0.10.24 test/plugin/in_object_space.rb
fluentd-0.10.23 test/plugin/in_object_space.rb
fluentd-0.10.22 test/plugin/in_object_space.rb
fluentd-0.10.21 test/plugin/in_object_space.rb
fluentd-0.10.20 test/plugin/in_object_space.rb
fluentd-0.10.19 test/plugin/in_object_space.rb
fluentd-0.10.18 test/plugin/in_object_space.rb
fluentd-0.10.17 test/plugin/in_object_space.rb
fluentd-0.10.16 test/plugin/in_object_space.rb