Sha256: f1e6697ada9bf221819abdd7f522e6f3df115ad673f7106ec1366723cecd6f24
Contents?: true
Size: 743 Bytes
Versions: 15
Compression:
Stored size: 743 Bytes
Contents
require 'open-uri'
require 'json'
require 'dply/error'
module Dplyr
class Consul
def hosts(app_name, service: "app")
uri = "http://127.0.0.1:8500/v1/catalog/service/#{service}?tag=#{app_name}"
response = JSON.parse(open(uri).read)
hosts = []
response.each do |i|
host = {}
metadata_tag = i["ServiceTags"].find {|t| t =~ /\Ametadata:/}
metadata = metadata_tag ? JSON.parse(metadata_tag.partition(":")[2]) : {}
host[:user] = metadata["user"]
host[:dir] = metadata["dir"]
host[:addr] = i["Address"]
host[:id] = i["Node"]
hosts << host
end
hosts
rescue
raise ::Dply::Error, "failed to load hosts from consul"
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems