Merge compass-tasks-osa and compass-tasks-k8s

JIRA: COMPASS-568

rename compass-tasks to compass-tasks-base.
add both osa and k8s support in compass-tasks

Change-Id: I438f5b17e509d4cb751ced0ffe640ec70899882f
Signed-off-by: Harry Huang <huangxiangyu5@huawei.com>

1 files changed, 0 insertions, 182 deletions

diff --git a/compass-tasks/actions/deploy.py b/compass-tasks/actions/deploy.py
deleted file mode 100644
index 53179f5..0000000
--- a/compass-tasks/actions/deploy.py
+++ /dev/null
@@ -1,182 +0,0 @@
-# Copyright 2014 Huawei Technologies Co. Ltd
-#
-# 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.
-
-"""Module to deploy a given cluster
-"""
-import logging
-
-from compass.actions import util
-from compass.db.api import cluster as cluster_db
-from compass.db.api import health_check_report as health_check_db
-from compass.db.api import user as user_db
-from compass.deployment.deploy_manager import DeployManager
-from compass.deployment.utils import constants as const
-
-
-def deploy(cluster_id, hosts_id_list, username=None):
-    """Deploy clusters.
-
-    :param cluster_hosts: clusters and hosts in each cluster to deploy.
-    :type cluster_hosts: dict of int or str to list of int or str
-
-    .. note::
-        The function should be called out of database session.
-    """
-    with util.lock('serialized_action', timeout=1000) as lock:
-        if not lock:
-            raise Exception('failed to acquire lock to deploy')
-
-        user = user_db.get_user_object(username)
-
-        cluster_info = util.ActionHelper.get_cluster_info(cluster_id, user)
-        adapter_id = cluster_info[const.ADAPTER_ID]
-
-        adapter_info = util.ActionHelper.get_adapter_info(
-            adapter_id, cluster_id, user)
-        hosts_info = util.ActionHelper.get_hosts_info(
-            cluster_id, hosts_id_list, user)
-
-        deploy_successful = True
-        try:
-            deploy_manager = DeployManager(
-                adapter_info, cluster_info, hosts_info)
-            # deploy_manager.prepare_for_deploy()
-            logging.debug('Created deploy manager with %s %s %s'
-                          % (adapter_info, cluster_info, hosts_info))
-            deployed_config = deploy_manager.deploy()
-        except Exception as error:
-            logging.exception(error)
-            deploy_successful = False
-
-        if deploy_successful:
-            util.ActionHelper.save_deployed_config(deployed_config, user)
-            util.ActionHelper.update_state(
-                cluster_id, hosts_id_list, user, state='INSTALLING'
-            )
-        else:
-            util.ActionHelper.update_state(
-                cluster_id, hosts_id_list, user, state='ERROR',
-                message='failed to start deployment', severity='ERROR'
-            )
-
-
-def redeploy(cluster_id, username=None):
-    """Deploy clusters.
-
-    :param cluster_hosts: clusters and hosts in each cluster to deploy.
-    :type cluster_hosts: dict of int or str to list of int or str
-    """
-    with util.lock('serialized_action') as lock:
-        if not lock:
-            raise Exception('failed to acquire lock to deploy')
-
-        user = user_db.get_user_object(username)
-        cluster_info = util.ActionHelper.get_cluster_info(cluster_id, user)
-        adapter_id = cluster_info[const.ADAPTER_ID]
-
-        adapter_info = util.ActionHelper.get_adapter_info(
-            adapter_id, cluster_id, user)
-
-        cluster_hosts = cluster_db.list_cluster_hosts(cluster_id, user)
-        hosts_id_list = [host['id'] for host in cluster_hosts]
-
-        hosts_info = util.ActionHelper.get_hosts_info(
-            cluster_id, hosts_id_list, user)
-
-        deploy_successful = True
-        try:
-            deploy_manager = DeployManager(
-                adapter_info, cluster_info, hosts_info)
-            # deploy_manager.prepare_for_deploy()
-            deploy_manager.redeploy()
-        except Exception as error:
-            logging.exception(error)
-            deploy_successful = False
-        if deploy_successful:
-            util.ActionHelper.update_state(
-                cluster_id, hosts_id_list, user, state='INSTALLING',
-            )
-        else:
-            util.ActionHelper.update_state(
-                cluster_id, hosts_id_list, user, state='ERROR',
-                message='failed to start redeployment', severity='ERROR'
-            )
-
-
-def health_check(cluster_id, report_uri, username):
-    with util.lock('cluster_health_check') as lock:
-        if not lock:
-            raise Exception('failed to acquire lock to check health')
-
-        user = user_db.get_user_object(username)
-        cluster_info = util.ActionHelper.get_cluster_info(cluster_id, user)
-        adapter_id = cluster_info[const.ADAPTER_ID]
-
-        adapter_info = util.ActionHelper.get_adapter_info(
-            adapter_id, cluster_id, user
-        )
-
-        deploy_manager = DeployManager(adapter_info, cluster_info, None)
-        try:
-            deploy_manager.check_cluster_health(report_uri)
-        except Exception as exc:
-            logging.error("health_check exception: ============= %s" % exc)
-            data = {'state': 'error', 'error_message': str(exc), 'report': {}}
-            reports = health_check_db.list_health_reports(
-                cluster_id, user=user)
-            if not reports:
-                # Exception before executing command remotely for health check.
-                # No reports names sending back yet. Create a report
-                name = 'pre_remote_health_check'
-                health_check_db.add_report_record(
-                    cluster_id, name, user=user, **data
-                )
-
-            health_check_db.update_multi_reports(cluster_id, user=user, **data)
-
-
-class ServerPowerMgmt(object):
-    """Power management for bare-metal machines by IPMI command."""
-    @staticmethod
-    def poweron(machine_id, user):
-        """Power on the specified machine."""
-        pass
-
-    @staticmethod
-    def poweroff(machine_id, user):
-        pass
-
-    @staticmethod
-    def reset(machine_id, user):
-        pass
-
-
-class HostPowerMgmt(object):
-    """Power management for hosts installed OS by OS installer. OS installer
-
-    will poweron/poweroff/reset host.
-
-    """
-    @staticmethod
-    def poweron(host_id, user):
-        """Power on the specified host."""
-        pass
-
-    @staticmethod
-    def poweroff(host_id, user):
-        pass
-
-    @staticmethod
-    def reset(host_id, user):
-        pass