Contents

require 'fluent/test'

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

  CONFIG = %[
    emit_interval 1
    tag t1
  ]

  def create_driver(conf=CONFIG)
    Fluent::Test::InputTestDriver.new(Fluent::StatusInput).configure(conf)
  end

  def test_configure
    d = create_driver
    assert_equal(1, d.instance.emit_interval)
    assert_equal("t1", d.instance.tag)
  end

  def test_emit
    stub(Fluent::Status).each { |b|
      b.call("answer" => "42")
    }

    d = create_driver
    d.run do
      sleep 2
    end

    emits = d.emits
    assert(emits.length > 0)
    assert_equal({"answer" => "42"}, emits[0][2])
  end
end

Version data entries

27 entries across 27 versions & 1 rubygems

Version	Path
fluentd-0.10.57	test/plugin/test_in_status.rb
fluentd-0.10.56	test/plugin/test_in_status.rb
fluentd-0.10.55	test/plugin/test_in_status.rb
fluentd-0.10.54	test/plugin/test_in_status.rb
fluentd-0.12.0.pre.1	test/plugin/test_in_status.rb
fluentd-0.10.53	test/plugin/test_in_status.rb
fluentd-0.10.52	test/plugin/test_in_status.rb
fluentd-0.10.51	test/plugin/test_in_status.rb
fluentd-0.10.50	test/plugin/test_in_status.rb
fluentd-0.10.49	test/plugin/test_in_status.rb
fluentd-0.10.48	test/plugin/test_in_status.rb
fluentd-0.10.47	test/plugin/test_in_status.rb
fluentd-0.10.46	test/plugin/test_in_status.rb
fluentd-0.10.45	test/plugin/in_status.rb
fluentd-0.10.44	test/plugin/in_status.rb
fluentd-0.10.43	test/plugin/in_status.rb
fluentd-0.10.42	test/plugin/in_status.rb
fluentd-0.10.41	test/plugin/in_status.rb
fluentd-0.10.40	test/plugin/in_status.rb
fluentd-0.10.39	test/plugin/in_status.rb