x/compass-adapters
Code Issues Proposed changes

haproxy backend servers' info can prefeed from databbag

Browse Source 
Change-Id: If7876d51416f36d9dabe04c122ed5551fd45ff74
This commit is contained in:
SamSu 2014-04-02 14:49:46 -07:00
parent 36ff13c7a2
commit 54cdeb7034
2 changed files with 33 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
chef/cookbooks/haproxy/attributes/default.rb
View File

@ -17,6 +17,12 @@
# limitations under the License.
#
# node['haproxy']['backend'] to deside where service backend sources come from
# if 'prefeed', all services' backend info will be choosen from databag
# 'node_mapping'; 'prefeed' is suitable for stable and independent services
# if 'autofeed', services' backend info will automaticly learn backend info
# from it's chef server.
default['haproxy']['choose_backend'] = 'prefeed'
default['haproxy']['enable_default_http'] = true
default['haproxy']['incoming_address'] = "0.0.0.0"
default['haproxy']['incoming_port'] = 80

39
chef/cookbooks/haproxy/recipes/tcp_lb.rb
View File

@ -51,26 +51,41 @@ node['haproxy']['services'].each do |name, service|
unless node['haproxy']['enabled_services'].include?(name)
next
end
pool_members = search(:node, "run_list:role\\[#{service['role']}\\] AND chef_environment:#{node.chef_environment}") || []
# load balancer may be in the pool
pool_members << node if node.run_list.roles.include?(service[:role])
if node['haproxy']['choose_backend'].eql?("prefeed")
pool_members = []
mydata['node_mapping'].each do |nodename, nodeinfo|
if nodeinfo['roles'].include?(service['role'])
pool_members << nodename
end
end
else
pool_members = search(:node, "run_list:role\\[#{service['role']}\\] AND chef_environment:#{node.chef_environment}") || []
# load balancer may be in the pool
pool_members << node if node.run_list.roles.include?(service[:role])
end
# we prefer connecting via local_ipv4 if
# pool members are in the same cloud
# TODO refactor this logic into library...see COOK-494
pool_members.map! do |member|
server_ip = begin
if member.attribute?('cloud')
if node.attribute?('cloud') && (member['cloud']['provider'] == node['cloud']['provider'])
member['cloud']['local_ipv4']
if node['haproxy']['choose_backend'].eql?("prefeed")
server_ip = mydata['node_mapping']["#{member}"]['management_ip']
{:ipaddress => server_ip, :hostname => member}
else
server_ip = begin
if member.attribute?('cloud')
if node.attribute?('cloud') && (member['cloud']['provider'] == node['cloud']['provider'])
member['cloud']['local_ipv4']
else
member['cloud']['public_ipv4']
end
else
member['cloud']['public_ipv4']
member['ipaddress']
end
else
member['ipaddress']
end
end
{:ipaddress => server_ip, :hostname => member['hostname']}
{:ipaddress => server_ip, :hostname => member['hostname']}
end
end
pool = ["options httpchk #{node['haproxy']['httpchk']}"] if node['haproxy']['httpchk']