X-Git-Url: https://gerrit.akraino.org/r/gitweb?a=blobdiff_plain;f=cmdatahandlers%2Fsrc%2Fcmdatahandlers%2Fstorage%2Fconfig.py;fp=cmdatahandlers%2Fsrc%2Fcmdatahandlers%2Fstorage%2Fconfig.py;h=c769338aaf2e77f21924768331eed7463c0fc9d2;hb=c389bdee7b3845b55f443dbf04c0ce4083a55886;hp=0000000000000000000000000000000000000000;hpb=5030f0c004701dd422c78c71c014ef60f48139fc;p=ta%2Fconfig-manager.git

diff --git a/cmdatahandlers/src/cmdatahandlers/storage/config.py b/cmdatahandlers/src/cmdatahandlers/storage/config.py
new file mode 100644
index 0000000..c769338
--- /dev/null
+++ b/cmdatahandlers/src/cmdatahandlers/storage/config.py
@@ -0,0 +1,394 @@
+# Copyright 2019 Nokia
+
+# 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.
+
+from cmdatahandlers.api import configerror
+from cmdatahandlers.api import config
+
+
+class Config(config.Config):
+    def __init__(self, confman):
+        super(Config, self).__init__(confman)
+        self.ROOT = 'cloud.storage'
+        self.DOMAIN = 'storage'
+
+    def init(self):
+        pass
+
+    def validate(self):
+        self.validate_root()
+        self._validate_storage_backends()
+
+    def _validate_storage_backends(self):
+        backends = self.get_storage_backends()
+        for backend in backends:
+            if backend == 'ceph':
+                self._validate_ceph_backend()
+            elif backend == 'external_ceph':
+                self._validate_external_ceph_backend()
+            elif backend == 'lvm':
+                self._validate_lvm_backend()
+            else:
+                raise configerror.ConfigError('Invalid backend %s specified' % backend)
+
+    def _validate_ceph_backend(self):
+        self.is_ceph_enabled()
+        osdpoolsize = self.get_ceph_osd_pool_size()
+        if osdpoolsize <= 1:
+            raise configerror.ConfigError('Invalid osd pool size configured %d' % osdpoolsize)
+
+    def _validate_external_ceph_backend(self):
+        self.is_external_ceph_enabled()
+        self.get_ext_ceph_fsid()
+        self.get_ext_ceph_mon_hosts()
+        self.get_ext_ceph_ceph_s3_endpoint()
+        self.get_ext_ceph_ceph_s3_keystone_user()
+        self.get_ext_ceph_ceph_s3_keystone_adminpw()
+        self.get_ext_ceph_ceph_user()
+        self.get_ext_ceph_ceph_user_key()
+        self.get_ext_ceph_cinder_pool()
+        self.get_ext_ceph_glance_pool()
+        self.get_ext_ceph_nova_pool()
+        self.get_ext_ceph_platform_pool()
+        self.get_ext_ceph_cidr()
+
+    def _validate_lvm_backend(self):
+        self.is_lvm_enabled()
+
+    def _set_hostlist(self, key, value):
+        self.validate_root()
+        if len(value) <= 0:
+            raise configerror.ConfigError('The host list for {} is empty'.format(key))
+        self.config[self.ROOT][key] = value
+
+    def get_storage_backends(self):
+        """ get the list of backends
+
+            Return:
+
+            A list of backend names
+
+            Raise:
+
+            ConfigError in-case of an error
+        """
+        self.validate_root()
+
+        if 'backends' not in self.config[self.ROOT]:
+            raise configerror.ConfigError('No backends configured')
+
+        return self.config[self.ROOT]['backends'].keys()
+
+    def get_ceph_osd_pool_size(self):
+        """ get the ceph osd pool size
+
+            Return:
+
+            The ceph osd pool size
+
+            Raise:
+
+            ConfigError in-case of an error
+        """
+        self.validate_root()
+        backends = self.get_storage_backends()
+
+        if 'ceph' not in backends:
+            raise configerror.ConfigError('No ceph backend configured')
+
+        if 'osd_pool_default_size' not in self.config[self.ROOT]['backends']['ceph']:
+            raise configerror.ConfigError('No ceph osd configuration found')
+
+        return self.config[self.ROOT]['backends']['ceph']['osd_pool_default_size']
+
+    def is_lvm_enabled(self):
+        """ Is lvm enabled or not.
+
+            Return:
+                True if lvm is enabled otherwise False.
+        """
+        return self.is_backend_enabled('lvm')
+
+    def is_ceph_enabled(self):
+        """ Is ceph enabled or not.
+
+            Return:
+                True if ceph is enabled otherwise False.
+        """
+        return self.is_backend_enabled('ceph')
+
+    def is_external_ceph_enabled(self):
+        """ Is external ceph enabled or not.
+
+            Return:
+                True if external ceph is enabled otherwise False.
+        """
+        return self.is_backend_enabled('external_ceph')
+
+    def is_backend_enabled(self, backend):
+        """ Is the given backend enabled.
+
+            Argument:
+                The storage backend.
+
+            Return:
+                True if the backend is enabled otherwise False.
+
+            Raise:
+                -
+        """
+        self.validate_root()
+        backends = self.get_storage_backends()
+
+        if backend not in backends:
+            return False
+
+        if 'enabled' not in self.config[self.ROOT]['backends'][backend]:
+            raise configerror.ConfigError(
+                'The enabled parameter not configured for {}'.format(backend))
+
+        return self.config[self.ROOT]['backends'][backend]['enabled']
+
+    def get_enabled_backends(self):
+        """ Gets enabled storage backends.
+
+            Argument:
+                The storage backend.
+
+            Return:
+                List of enabled backends.
+        """
+        return [backend for backend, values in self.config[self.ROOT]['backends'].iteritems()
+                if values.get('enabled', False)]
+
+    def set_mons(self, hosts):
+        """ Set the ceph monitors
+
+            Argument:
+
+            A list of ceph monitor hosts.
+
+            Raise:
+
+            ConfigError in-case of an error
+        """
+        self._set_hostlist('mons', hosts)
+
+    def set_ceph_mons(self, hosts):
+        """ Set the ceph monitors for openstack-ansible.
+
+            Argument:
+
+            A list of ceph monitor hosts.
+
+            Raise:
+
+            ConfigError in-case of an error
+        """
+        self._set_hostlist('ceph_mons', hosts)
+
+    def set_osds(self, hosts):
+        """ Set the ceph osds
+
+            Argument:
+
+            A list of ceph osd hosts.
+
+            Raise:
+
+            ConfigError in-case of an error
+        """
+        self._set_hostlist('osds', hosts)
+
+    def _get_external_ceph_attribute(self, attribute):
+        return self._get_backends_attribute('external_ceph', attribute)
+
+    def _is_valid_backend(self, backend):
+        self.validate_root()
+        if backend not in self.config[self.ROOT]['backends']:
+            raise configerror.ConfigError(
+                'The cloud.storage.backends does not have the '
+                'backend {} configured'.format(backend))
+
+    def _is_valid_backends_attribute(self, backend, attribute):
+        self.validate_root()
+        if attribute not in self.config[self.ROOT]['backends'][backend]:
+            raise configerror.ConfigError(
+                'The cloud.storage.backends.{} does not have '
+                'the attribute {} configured'.format(backend, attribute))
+
+    def _get_backends_attribute(self, backend, attribute):
+        self.validate_root()
+        self._is_valid_backend(backend)
+        self._is_valid_backends_attribute(backend, attribute)
+        return self.config[self.ROOT]['backends'][backend][attribute]
+
+    def get_ext_ceph_fsid(self):
+        """ Get the file system id of the external ceph cluster.
+
+            Return:
+                The fsid of the external ceph cluster.
+
+            Raise:
+                ConfigError in-case of an error
+        """
+        return self._get_external_ceph_attribute('fsid')
+
+    def get_ext_ceph_mon_hosts(self):
+        """ Get the monitor hosts of the external ceph system.
+
+            Return:
+                A list of monitor hosts.
+
+            Raise:
+                ConfigError in-case of an error
+        """
+        return self._get_external_ceph_attribute('mon_hosts')
+
+    def get_ext_ceph_ceph_s3_endpoint(self):
+        """ Get the ceph s3 endpoint. The endpoint consists of a
+            service name and port.
+
+            Return:
+                A ceph s3 endpoint in format: <service>:<port>
+
+            Raise:
+                ConfigError in-case of an error
+        """
+        return self._get_external_ceph_attribute('ceph_s3_endpoint')
+
+    def get_ext_ceph_ceph_s3_keystone_user(self):
+        """ Get the ceph s3 endpoint user.
+
+            Return:
+                The external ceph s3 keystone user.
+
+            Raise:
+                ConfigError in-case of an error.
+        """
+        return self._get_external_ceph_attribute('ceph_s3_keystone_user')
+
+    def get_ext_ceph_ceph_s3_keystone_adminpw(self):
+        """ Get the ceph s3 endpoint adminpw.
+
+            Return:
+                The external ceph s3 keystone adminpw.
+
+            Raise:
+                ConfigError in-case of an error.
+        """
+        return self._get_external_ceph_attribute('ceph_s3_keystone_adminpw')
+
+    def get_ext_ceph_ceph_user(self):
+        """ Get the ceph user of the external ceph server.
+
+            Return:
+                The external ceph user.
+
+            Raise:
+                ConfigError in-case of an error
+        """
+        return self._get_external_ceph_attribute('ceph_user')
+
+    def get_ext_ceph_ceph_user_key(self):
+        """ Get the external ceph server ceph user key.
+
+            Return:
+                The external ceph user key.
+
+            Raise:
+                ConfigError in-case of an error
+        """
+        return self._get_external_ceph_attribute('ceph_user_key')
+
+    def get_ext_ceph_cinder_pool(self):
+        """ Get the external ceph server cinder pool name.
+
+            Return:
+                External ceph server cinder pool name.
+
+            Raise:
+                ConfigError in-case of an error
+        """
+        return self._get_external_ceph_attribute('cinder_pool')
+
+    def get_ext_ceph_glance_pool(self):
+        """ Get the external ceph server glance pool name.
+
+            Return:
+                External ceph server glance pool name.
+
+            Raise:
+                ConfigError in-case of an error
+        """
+        return self._get_external_ceph_attribute('glance_pool')
+
+    def get_ext_ceph_nova_pool(self):
+        """ Get the external ceph server nova pool name.
+
+            Return:
+                External ceph server nova pool name.
+
+            Raise:
+                ConfigError in-case of an error
+        """
+        return self._get_external_ceph_attribute('nova_pool')
+
+    def get_ext_ceph_platform_pool(self):
+        """ Get the external ceph server platform pool name.
+
+            Return:
+                External ceph server platform pool name.
+
+            Raise:
+                ConfigError in-case of an error
+        """
+        return self._get_external_ceph_attribute('platform_pool')
+
+    def get_ext_ceph_cidr(self):
+        """ Get the external ceph cidr.
+
+            Return:
+                External ceph cidr.
+
+            Raise:
+                ConfigError in-case of an error
+        """
+        return self._get_external_ceph_attribute('cidr')
+
+    def set_ceph_enabled(self):
+        """ Set the ceph enabled
+
+            Raise:
+
+            ConfigError in-case of an error
+        """
+
+        if 'backends' not in self.config[self.ROOT]:
+            raise configerror.ConfigError('No backends configured')
+
+        if 'external_ceph' in self.config[self.ROOT]['backends']:
+            return
+
+        if self.is_lvm_enabled():
+            return
+
+        try:
+            self.is_ceph_enabled()
+        except configerror.ConfigError:
+            self.config[self.ROOT]['backends']['ceph'].update({"enabled": True})
+
+    def mask_sensitive_data(self):
+        if 'external_ceph' in self.get_storage_backends():
+            self.config[self.ROOT]['backends']['external_ceph']['ceph_user_key'] = self.MASK
+            self.config[self.ROOT]['backends']['external_ceph']['ceph_s3_keystone_adminpw'] = self.MASK