c741059eda
Here we move db and mq attributes already present in default.rb
attributes into new files (database.rb,messaging.rb). Additionally, we
pull in rabbit/mq attributes from
openstack-{block-storage,compute,image,metering,network} while
transforming namespace from openstack.SERVICE.mq and
openstack.SERVICE.rabbit to openstack.mq.SERVICE
and openstack.mq.SERVICE.rabbit. Lastly, we copy
openstack.SERVICE.db.username attribute from
openstack-{compute,dashboard,identity,image,metering,network} while
transforming namespace to openstack.db.SERVICE.username.
Change-Id: I50c900aa2ba92ce53f4a6ad05aeabd59e701b514
Implements: blueprint clean-up-attr-for-mq-and-db
94 lines
2.9 KiB
Ruby
94 lines
2.9 KiB
Ruby
#
|
|
# Cookbook Name:: openstack-common
|
|
# library:: endpoints
|
|
#
|
|
# Copyright 2012-2013, AT&T Services, Inc.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
#
|
|
|
|
require "uri"
|
|
|
|
module ::Openstack
|
|
# Shortcut to get the full URI for an endpoint. If the "uri" key isn't
|
|
# set in the endpoint hash, we use the ::Openstack.get_uri_from_mash
|
|
# library routine from the openstack-common cookbook to grab a URI object
|
|
# and construct the URI object from the endpoint parts.
|
|
def endpoint name
|
|
ep = endpoint_for name
|
|
if ep && ep['uri']
|
|
::URI.parse ::URI.encode(ep['uri'])
|
|
elsif ep
|
|
uri_from_hash ep
|
|
end
|
|
end
|
|
|
|
# Useful for iterating over the OpenStack endpoints
|
|
def endpoints &block
|
|
node['openstack']['endpoints'].each do | name, info |
|
|
block.call(name, info)
|
|
end
|
|
rescue
|
|
nil
|
|
end
|
|
|
|
# Instead of specifying the verbose node["openstack"]["db"][service],
|
|
# this shortcut allows the simpler and shorter db(service), where
|
|
# service is one of 'compute', 'image', 'identity', 'network',
|
|
# and 'volume'
|
|
def db service
|
|
node['openstack']['db'][service]
|
|
rescue
|
|
nil
|
|
end
|
|
|
|
# Shortcut to get the SQLAlchemy DB URI for a named service
|
|
def db_uri service, user, pass
|
|
info = db(service)
|
|
if info
|
|
host = info['host']
|
|
port = info['port'].to_s
|
|
type = info['service_type']
|
|
name = info['db_name']
|
|
if type == "pgsql"
|
|
# Normalize to the SQLAlchemy standard db type identifier
|
|
type = "postgresql"
|
|
end
|
|
case type
|
|
when "postgresql"
|
|
result = "#{type}://#{user}:#{pass}@#{host}:#{port}/#{name}"
|
|
when "mysql"
|
|
result = "#{type}://#{user}:#{pass}@#{host}:#{port}/#{name}?charset=utf8"
|
|
when "sqlite"
|
|
# SQLite uses filepaths not db name
|
|
# README(galstrom): 3 slashes is a relative path, 4 slashes is an absolute path
|
|
# example: info['path'] = 'path/to/foo.db' -- will return sqlite:///foo.db
|
|
# example: info['path'] = '/path/to/foo.db' -- will return sqlite:////foo.db
|
|
path = info['path']
|
|
result = "sqlite:///#{path}"
|
|
when "db2"
|
|
result = "ibm_db_sa://#{user}:#{pass}@#{host}:#{port}/#{name}?charset=utf8"
|
|
end
|
|
end
|
|
end
|
|
|
|
private
|
|
# Instead of specifying the verbose node["openstack"]["endpoints"][name],
|
|
# this shortcut allows the simpler and shorter endpoint(name)
|
|
def endpoint_for name
|
|
node['openstack']['endpoints'][name]
|
|
rescue
|
|
nil
|
|
end
|
|
end
|