"""Classes used by client.py""" # -*- coding: utf-8 -*- #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 paramiko import time import string import os.path ID_RSA_PATH = '/home/opnfv/.ssh/id_rsa' SSH_KEYS_SCRIPT = '/home/opnfv/barometer/baro_utils/get_ssh_keys.sh' DEF_PLUGIN_INTERVAL = 10 COLLECTD_CONF = '/etc/collectd/collectd.conf' COLLECTD_CONF_DIR = '/etc/collectd/collectd.conf.d' class Node(object): """Node configuration class""" def __init__(self, attrs): self.__id = int(attrs[0]) self.__status = attrs[1] self.__name = attrs[2] self.__cluster = int(attrs[3]) if attrs[3] else None self.__ip = attrs[4] self.__mac = attrs[5] self.__roles = [x.strip(' ') for x in attrs[6].split(',')] self.__pending_roles = attrs[7] self.__online = int(attrs[8]) if attrs[3] and attrs[8]else None self.__group_id = int(attrs[9]) if attrs[3] else None def get_name(self): """Get node name""" return self.__name def get_id(self): """Get node ID""" return self.__id def get_ip(self): """Get node IP address""" return self.__ip def get_roles(self): """Get node roles""" return self.__roles class ConfigServer(object): """Class to get env configuration""" def __init__(self, host, user, logger, passwd=None): self.__host = host self.__user = user self.__passwd = passwd self.__priv_key = None self.__nodes = list() self.__logger = logger self.__private_key_file = ID_RSA_PATH if not os.path.isfile(self.__private_key_file): self.__logger.error( "Private key file '{}'".format(self.__private_key_file) + " not found. Please try to run {} script.".format(SSH_KEYS_SCRIPT)) raise IOError("Private key file '{}' not found.".format(self.__private_key_file)) # get list of available nodes ssh, sftp = self.__open_sftp_session(self.__host, self.__user, self.__passwd) attempt = 1 fuel_node_passed = False while (attempt <= 10) and not fuel_node_passed: stdin, stdout, stderr = ssh.exec_command("fuel node") stderr_lines = stderr.readlines() if stderr_lines: self.__logger.warning("'fuel node' command failed (try {}):".format(attempt)) for line in stderr_lines: self.__logger.debug(line.strip()) else: fuel_node_passed = True if attempt > 1: self.__logger.info("'fuel node' command passed (try {})".format(attempt)) attempt += 1 if not fuel_node_passed: self.__logger.error("'fuel node' command failed. This was the last try.") raise OSError("'fuel node' command failed. This was the last try.") node_table = stdout.readlines()\ # skip table title and parse table values for entry in node_table[2:]: self.__nodes.append(Node([str(x.strip(' \n')) for x in entry.split('|')])) def get_controllers(self): """Get list of controllers""" return [node for node in self.__nodes if 'controller' in node.get_roles()] def get_computes(self): """Get list of computes""" return [node for node in self.__nodes if 'compute' in node.get_roles()] def get_nodes(self): """Get list of nodes""" return self.__nodes def __open_sftp_session(self, host, user, passwd=None): """Connect to given host. Keyword arguments: host -- host to connect user -- user to use passwd -- password to use Return tuple of SSH and SFTP client instances. """ # create SSH client ssh = paramiko.SSHClient() ssh.set_missing_host_key_polic
---
docker_images:
dovetail:
domain: opnfv
tag: latest
store_name: image_dovetail.docker
functest:
domain: opnfv
tag: latest
store_name: image_functest.docker
yardstick:
domain: opnfv
tag: latest
store_name: image_yardstick.docker
testapi:
domain: opnfv
tag: latest
store_name: image_testapi.docker
mongo:
tag: 3.5
store_name: image_mongo.docker
docker_save_path: /home/opnfv/dovetail/results/