02c5cb4a00
Change any and all internal variables, contants, or class names to reference "sahara" rather than "savanna". Also remove 'Savanna' from NA comments marking intentional divergence from the nova client. Map the 'savanna_url' param to 'sahara_url' in the savannaclient to make sure the change in saharaclient.api.Client.__init__ does not break existing code. Partial-implements: blueprint savanna-renaming-client Change-Id: Ia537a4d43036b44c05a399de0d04482e6029c6bc
77 lines
2.8 KiB
Python
77 lines
2.8 KiB
Python
# 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.
|
|
|
|
from saharaclient.api import parameters as params
|
|
|
|
|
|
class Helpers(object):
|
|
def __init__(self, sahara_client):
|
|
self.sahara = sahara_client
|
|
self.plugins = self.sahara.plugins
|
|
|
|
def _get_node_processes(self, plugin):
|
|
processes = []
|
|
for proc_lst in plugin.node_processes.values():
|
|
processes += proc_lst
|
|
|
|
return [(proc_name, proc_name) for proc_name in processes]
|
|
|
|
def get_node_processes(self, plugin_name, hadoop_version):
|
|
plugin = self.plugins.get_version_details(plugin_name, hadoop_version)
|
|
|
|
return self._get_node_processes(plugin)
|
|
|
|
def _extract_parameters(self, configs, scope, applicable_target):
|
|
parameters = []
|
|
for config in configs:
|
|
if (config['scope'] == scope and
|
|
config['applicable_target'] == applicable_target):
|
|
|
|
parameters.append(params.Parameter(config))
|
|
|
|
return parameters
|
|
|
|
def get_cluster_general_configs(self, plugin_name, hadoop_version):
|
|
plugin = self.plugins.get_version_details(plugin_name, hadoop_version)
|
|
|
|
return self._extract_parameters(plugin.configs, 'cluster', "general")
|
|
|
|
def get_general_node_group_configs(self, plugin_name, hadoop_version):
|
|
plugin = self.plugins.get_version_details(plugin_name, hadoop_version)
|
|
|
|
return self._extract_parameters(plugin.configs, 'node', 'general')
|
|
|
|
def get_targeted_node_group_configs(self, plugin_name, hadoop_version):
|
|
plugin = self.plugins.get_version_details(plugin_name, hadoop_version)
|
|
|
|
parameters = dict()
|
|
|
|
for service in plugin.node_processes.keys():
|
|
parameters[service] = self._extract_parameters(plugin.configs,
|
|
'node', service)
|
|
|
|
return parameters
|
|
|
|
def get_targeted_cluster_configs(self, plugin_name, hadoop_version):
|
|
plugin = self.plugins.get_version_details(plugin_name, hadoop_version)
|
|
|
|
parameters = dict()
|
|
|
|
for service in plugin.node_processes.keys():
|
|
parameters[service] = self._extract_parameters(plugin.configs,
|
|
'cluster', service)
|
|
|
|
return parameters
|