Method: Fluent::Test::Driver::BaseOwner#configure

Defined in:
lib/fluent/test/driver/base_owner.rb

#configure(conf, syntax: :v1) ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
 
# File 'lib/fluent/test/driver/base_owner.rb', line 37

def configure(conf, syntax: :v1)
  if conf.is_a?(Fluent::Config::Element)
    @config = conf
  else
    @config = Config.parse(conf, "(test)", "(test_dir)", syntax: syntax)
  end

  if @instance.respond_to?(:router=)
    @event_streams = []
    @error_events = []

    driver = self
    mojule = Module.new do
      define_method(:event_emitter_router) do |label_name|
        TestEventRouter.new(driver)
      end
    end
    @instance.singleton_class.prepend mojule
  end

  @instance.configure(@config)
  self
end