# Copyright (c) 2013 Mirantis 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. import itertools # loading keystonemiddleware opts because sahara uses these options in code from keystonemiddleware import opts # noqa from oslo_config import cfg from oslo_config import types from oslo_log import log from sahara import exceptions as ex from sahara.i18n import _ from sahara.plugins import base as plugins_base from sahara.topology import topology_helper from sahara.utils.notification import sender from sahara.utils.openstack import cinder from sahara.utils.openstack import keystone from sahara.utils import remote from sahara import version PORT_TYPE = types.Integer(1, 65535) cli_opts = [ cfg.StrOpt('host', default='', help='Hostname or IP address that will be used to listen on.'), cfg.Opt('port', default=8386, type=PORT_TYPE, help='Port that will be used to listen on.'), cfg.BoolOpt('log-exchange', default=False, help='Log request/response exchange details: environ, ' 'headers and bodies.') ] edp_opts = [ cfg.IntOpt('job_binary_max_KB', default=5120, help='Maximum length of job binary data in kilobytes that ' 'may be stored or retrieved in a single operation.'), cfg.IntOpt('job_canceling_timeout', default=300, help='Timeout for canceling job execution (in seconds). ' 'Sahara will try to cancel job execution during ' 'this time.') ] db_opts = [ cfg.StrOpt('db_driver', default='sahara.db', help='Driver to use for database access.') ] networking_opts = [ cfg.BoolOpt('use_floating_ips', default=True, help='If set to True, Sahara will use floating IPs to ' 'communicate with instances. To make sure that all ' 'instances have floating IPs assigned in Nova Network ' 'set "auto_assign_floating_ip=True" in nova.conf. ' 'If Neutron is used for networking, make sure that ' 'all Node Groups have "floating_ip_pool" parameter ' 'defined.'), cfg.StrOpt('node_domain', default='novalocal', help="The suffix of the node's FQDN. In nova-network that is " "the dhcp_domain config parameter."), cfg.BoolOpt('use_neutron', default=False, help="Use Neutron Networking (False indicates the use of Nova " "networking)."), cfg.BoolOpt('use_namespaces', default=False, help="Use network namespaces for communication (only valid to " "use in conjunction with use_neutron=True)."), cfg.BoolOpt('use_rootwrap', default=False, help="Use rootwrap facility to allow non-root users to run " "the sahara-all server instance and access private " "network IPs (only valid to use in conjunction with " "use_namespaces=True)"), cfg.StrOpt('rootwrap_command', default='sudo sahara-rootwrap /etc/sahara/rootwrap.conf', help="Rootwrap command to leverage. Use in conjunction with " "use_rootwrap=True") ] CONF = cfg.CONF CONF.register_cli_opts(cli_opts) CONF.register_opts(networking_opts) CONF.register_opts(edp_opts) CONF.register_opts(db_opts) log.register_options(CONF) log.set_defaults(default_log_levels=[ 'amqplib=WARN', 'qpid.messaging=INFO', 'stevedore=INFO', 'eventlet.wsgi.server=WARN', 'sqlalchemy=WARN', 'boto=WARN', 'suds=INFO', 'keystone=INFO', 'paramiko=WARN', 'requests=WARN', 'iso8601=WARN', 'oslo_messaging=INFO', 'neutronclient=INFO', ]) def list_opts(): # NOTE (vgridnev): we make these import here to avoid problems # with importing unregistered options in sahara code. # As example, importing 'node_domain' in # sahara/conductor/objects.py from sahara.conductor import api from sahara import main as sahara_main from sahara.service.edp import job_utils from sahara.service.heat import heat_engine from sahara.service import periodic from sahara.swift import swift_helper from sahara.utils import cluster_progress_ops as cpo from sahara.utils.openstack import base from sahara.utils.openstack import heat from sahara.utils.openstack import neutron from sahara.utils.openstack import nova from sahara.utils.openstack import swift from sahara.utils import poll_utils from sahara.utils import proxy from sahara.utils import wsgi return [ (None, itertools.chain(cli_opts, edp_opts, networking_opts, db_opts, plugins_base.opts, topology_helper.opts, sender.notifier_opts, keystone.opts, remote.ssh_opts, sahara_main.opts, job_utils.opts, periodic.periodic_opts, proxy.opts, cpo.event_log_opts, wsgi.wsgi_opts, base.opts, heat_engine.heat_engine_opts)), (poll_utils.timeouts.name, itertools.chain(poll_utils.timeouts_opts)), (api.conductor_group.name, itertools.chain(api.conductor_opts)), (cinder.cinder_group.name, itertools.chain(cinder.opts)), (heat.heat_group.name, itertools.chain(heat.opts)), (neutron.neutron_group.name, itertools.chain(neutron.opts)), (nova.nova_group.name, itertools.chain(nova.opts)), (swift.swift_group.name, itertools.chain(swift.opts)), (keystone.keystone_group.name, itertools.chain(keystone.ssl_opts)), (base.retries.name, itertools.chain(base.opts)), (swift_helper.public_endpoint_cert_group.name, itertools.chain(swift_helper.opts)) ] def parse_configs(conf_files=None): try: version_string = version.version_info.version_string() CONF(project='sahara', version=version_string, default_config_files=conf_files) except cfg.RequiredOptError as roe: raise ex.ConfigurationError( _("Option '%(option)s' is required for config group '%(group)s'") % {'option': roe.opt_name, 'group': roe.group.name}) validate_configs() def validate_network_configs(): if CONF.use_namespaces and not CONF.use_neutron: raise ex.ConfigurationError( _('use_namespaces can not be set to "True" when use_neutron ' 'is set to "False"')) def validate_configs(): validate_network_configs()