class Philae::EtcdClusterProbe

Attributes

etcd_probes[R]
name[R]

Public Class Methods

new(name, endpoints, read_timeout: 1, cacert: nil, ssl_cert: nil, ssl_key: nil) click to toggle source

@param [Integer] read_timeout Timeout in second for the HTTP request

# File lib/philae/etcd_cluster_probe.rb, line 9
def initialize(name, endpoints, read_timeout: 1, cacert: nil, ssl_cert: nil, ssl_key: nil)
  raise ArgumentError, 'empty endpoints' if endpoints.nil? || endpoints.empty?

  @etcd_probes = endpoints.map do |endpoint|
    endpoint_uri = URI(endpoint)
    next EtcdProbe.new(
      "#{name}-#{endpoint_uri.host}-#{endpoint_uri.port}",
      endpoint_uri.host,
      endpoint_uri.port,
      read_timeout: read_timeout, cacert: cacert,
      ssl_cert: ssl_cert, ssl_key: ssl_key,
    )
  end

  @name = name
end

Public Instance Methods

probes() click to toggle source
# File lib/philae/etcd_cluster_probe.rb, line 26
def probes
  return @etcd_probes
end