Method: Fluent::Plugin::FileServiceDiscovery#start

Defined in:
lib/fluent/plugin/sd_file.rb

#start(queue) ⇒ Object 



59
60
61
62
63
64
65
66
 
# File 'lib/fluent/plugin/sd_file.rb', line 59

def start(queue)
  watcher = StatWatcher.new(@path, @log) do |_prev, _cur|
    refresh_file(queue)
  end
  event_loop_attach(watcher)

  super()
end