Class: Fluent::Plugin::DnsServiceDiscovery

Inherits:
ServiceDiscovery
  • Object
show all
Includes:
PluginHelper::Mixin
Defined in:
lib/fluent/plugin/sd_dns.rb

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



62
63
64
65
 
# File 'lib/fluent/plugin/sd_dns.rb', line 62

def configure(conf)
  super
  @services = fetch_services_from_dns
end

#start(queue) ⇒ Object 



67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/fluent/plugin/sd_dns.rb', line 67

def start(queue)
  if @interval
    timer_execute(:"sd_dns_refresh", @interval) do
      refresh_service_list(queue)
    end
  else
    refresh_service_list(queue)
  end

  super()
end