diff options
Diffstat (limited to 'sdv/docker/sdvstate/internal/validator/kuberef/policy_checks.py')
-rw-r--r-- | sdv/docker/sdvstate/internal/validator/kuberef/policy_checks.py | 123 |
1 files changed, 123 insertions, 0 deletions
diff --git a/sdv/docker/sdvstate/internal/validator/kuberef/policy_checks.py b/sdv/docker/sdvstate/internal/validator/kuberef/policy_checks.py new file mode 100644 index 0000000..6993fd7 --- /dev/null +++ b/sdv/docker/sdvstate/internal/validator/kuberef/policy_checks.py @@ -0,0 +1,123 @@ +""" +Policy Checks +Checks if the policies are properly configured +""" + + +import ast +import logging +from tools.kube_utils import kube_api +from tools.conf import settings +from internal.store_result import store_result + +def cpu_manager_policy_check(): + """ + Checks cpu manager settings + """ + api = kube_api() + logger = logging.getLogger(__name__) + node_list = api.list_node() + nodes = [] + + for node in node_list: + nodes.append(node.metadata.name) + + result = {'category': 'compute', + 'case_name': 'cpu_manager_policy_check', + 'criteria': 'pass', + 'details': [] + } + + for node in nodes: + configz = api.connect_get_node_proxy_with_path(node, "configz") + configz = ast.literal_eval(configz) + res = { + 'node': node, + 'criteria': 'pass', + 'config': [] + } + + status = [] + + flag = True + + cpu_manager = settings.getValue('pdf_file')['vim_functional']['cpu_manager_policy'] + + if cpu_manager['type'] == configz['kubeletconfig']['cpuManagerPolicy']: + if cpu_manager['type'] == 'static': + if cpu_manager['reconcile_period'] == configz['kubeletconfig']['cpuManagerReconcilePeriod']: + if cpu_manager['full_pcpus'] == configz['kubeletconfig']['full-pcpus-only']: + flag = flag and True + else: + flag = flag and False + else: + flag = flag and True + else: + flag = flag and False + + if flag is False: + res['criteria'] = 'fail' + + status.append(cpu_manager) + res['config'] = status + result['details'].append(res) + + + if flag is False: + result['criteria'] = 'fail' + + store_result(logger, result) + return result + +def topology_manager_policy_check(): + """ + Checks topology manager settings + """ + api = kube_api() + logger = logging.getLogger(__name__) + node_list = api.list_node() + nodes = [] + + for node in node_list: + nodes.append(node.metadata.name) + + + result = { + 'category': 'compute', + 'case_name': 'topology_manager_policy_check', + 'criteria': 'pass', + 'details': [] + } + + for node in nodes: + configz = api.connect_get_node_proxy_with_path(node, "configz") + configz = ast.literal_eval(configz) + res = { + 'node': node, + 'criteria': 'pass', + 'config': [] + } + + status = [] + + flag = True + + topology_manager = settings.getValue('pdf_file')['undercloud_ook']['topo_manager_policy'] + + if topology_manager['type'] == configz['kubeletconfig']['topologyManagerPolicy']: + if topology_manager['scope'] == configz['kubeletconfig']['topologyManagerScope']: + flag = flag and True + else: + flag = flag and False + if flag is False: + res['criteria'] = 'fail' + + status.append(topology_manager) + res['config'] = status + result['details'].append(res) + + if flag is False: + result['criteria'] = 'fail' + + store_result(logger, result) + return result |