Method: Fluent::Plugin::SrvServiceDiscovery#start

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

#start(queue) ⇒ Object



72
73
74
75
76
77
78
# File 'lib/fluent/plugin/sd_srv.rb', line 72

def start(queue)
  timer_execute(:"sd_srv_record_#{@target}", @interval) do
    refresh_srv_records(queue)
  end

  super()
end