Method: Fluent::Plugin::SrvServiceDiscovery#configure

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

#configure(conf) ⇒ Object 



55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/fluent/plugin/sd_srv.rb', line 55

def configure(conf)
  super

  @target = "_#{@service}._#{@proto}.#{@hostname}"
  @dns_resolve =
    if @dns_server_host.nil?
      Resolv::DNS.new
    elsif @dns_server_host.include?(':') # e.g. 127.0.0.1:8600
      host, port = @dns_server_host.split(':', 2)
      Resolv::DNS.new(nameserver_port: [[host, port.to_i]])
    else
      Resolv::DNS.new(nameserver: @dns_server_host)
    end

  @services = fetch_srv_record
end