class Consul::Async::ConsulTemplateServices

Object returned by services() an abstract map of service_name, tags

Public Class Methods

new(consul_endpoint) click to toggle source
# File lib/consul/async/consul_template.rb, line 587
def initialize(consul_endpoint)
  super(consul_endpoint)
end

Public Instance Methods

parse_result(res) click to toggle source
# File lib/consul/async/consul_template.rb, line 591
def parse_result(res)
  return res unless res.data == '{}' || endpoint.query_params[:tag]

  res_json = JSON.parse(res.data)
  result = {}
  res_json.each do |name, tags|
    result[name] = tags if tags.include? endpoint.query_params[:tag]
  end
  res.mutate(JSON.generate(result))
  res
end