Class: Puppet::HTTP::Resolver::SRV

Inherits:
Puppet::HTTP::Resolver show all
Defined in:
lib/puppet/http/resolver/srv.rb

Overview

Resolve a service using DNS SRV records.

API:

  • public

Instance Method Summary collapse

Methods inherited from Puppet::HTTP::Resolver

#check_connection?

Constructor Details

#initialize(client, domain:, dns: Resolv::DNS.new) ⇒ SRV

Create an DNS SRV resolver.

Parameters:

  • srv domain

  • (defaults to: Resolv::DNS.new)

API:

  • public



13
14
15
16
17
 
# File 'lib/puppet/http/resolver/srv.rb', line 13

def initialize(client, domain:, dns: Resolv::DNS.new)
  @client = client
  @srv_domain = domain
  @delegate = Puppet::HTTP::DNS.new(dns)
end

Instance Method Details

#resolve(session, name, ssl_context: nil, canceled_handler: nil) ⇒ Puppet::HTTP::Service

Walk the available srv records and return the first that successfully connects

Parameters:

  • the service being resolved

  • (defaults to: nil)
  • (defaults to: nil)

    optional callback allowing a resolver to cancel resolution.

Returns:

  • if an available service is found, return it. Return nil otherwise.

API:

  • public



31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/puppet/http/resolver/srv.rb', line 31

def resolve(session, name, ssl_context: nil, canceled_handler: nil)
  # Here we pass our HTTP service name as the DNS SRV service name
  # This is fine for :ca, but note that :puppet and :file are handled
  # specially in `each_srv_record`.
  @delegate.each_srv_record(@srv_domain, name) do |server, port|
    service = Puppet::HTTP::Service.create_service(@client, session, name, server, port)
    return service if check_connection?(session, service, ssl_context: ssl_context)
  end

  nil
end