heat.engine.clients.os.senlin

Source code for heat.engine.clients.os.senlin

#
#    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 openstack import exceptions

from heat.common import exception
from heat.common.i18n import _
from heat.engine.clients.os import openstacksdk as sdk_plugin
from heat.engine import constraints

CLIENT_NAME = 'senlin'


[docs]class SenlinClientPlugin(sdk_plugin.OpenStackSDKPlugin): exceptions_module = exceptions def _create(self, version=None): client = super(SenlinClientPlugin, self)._create(version=version) return client.clustering def _get_additional_create_args(self, version): return { 'clustering_api_version': version or '1' }
[docs] def generate_spec(self, spec_type, spec_props): spec = {'properties': spec_props} spec['type'], spec['version'] = spec_type.split('-') return spec
[docs] def check_action_status(self, action_id): action = self.client().get_action(action_id) if action.status == 'SUCCEEDED': return True elif action.status == 'FAILED': raise exception.ResourceInError( status_reason=action.status_reason, resource_status=action.status, ) return False
[docs] def get_profile_id(self, profile_name): profile = self.client().get_profile(profile_name) return profile.id
[docs] def get_cluster_id(self, cluster_name): cluster = self.client().get_cluster(cluster_name) return cluster.id
[docs] def get_policy_id(self, policy_name): policy = self.client().get_policy(policy_name) return policy.id
[docs] def is_bad_request(self, ex): return (isinstance(ex, exceptions.HttpException) and ex.status_code == 400)
[docs] def execute_actions(self, actions): all_executed = True for action in actions: if action['done']: continue all_executed = False if action['action_id'] is None: func = getattr(self.client(), action['func']) ret = func(**action['params']) if isinstance(ret, dict): action['action_id'] = ret['action'] else: action['action_id'] = ret.location.split('/')[-1] else: ret = self.check_action_status(action['action_id']) action['done'] = ret # Execute these actions one by one. break return all_executed
[docs]class ProfileConstraint(constraints.BaseCustomConstraint): # If name is not unique, will raise exceptions.HttpException expected_exceptions = (exceptions.HttpException,)
[docs] def validate_with_client(self, client, profile): client.client(CLIENT_NAME).get_profile(profile)
[docs]class ClusterConstraint(constraints.BaseCustomConstraint): # If name is not unique, will raise exceptions.HttpException expected_exceptions = (exceptions.HttpException,)
[docs] def validate_with_client(self, client, value): client.client(CLIENT_NAME).get_cluster(value)
[docs]class PolicyConstraint(constraints.BaseCustomConstraint): # If name is not unique, will raise exceptions.HttpException expected_exceptions = (exceptions.HttpException,)
[docs] def validate_with_client(self, client, value): client.client(CLIENT_NAME).get_policy(value)
[docs]class ProfileTypeConstraint(constraints.BaseCustomConstraint): expected_exceptions = (exception.StackValidationFailed,)
[docs] def validate_with_client(self, client, value): conn = client.client(CLIENT_NAME) type_list = conn.profile_types() names = [pt.name for pt in type_list] if value not in names: not_found_message = ( _("Unable to find senlin profile type '%(pt)s', " "available profile types are %(pts)s.") % {'pt': value, 'pts': names} ) raise exception.StackValidationFailed(message=not_found_message)
[docs]class PolicyTypeConstraint(constraints.BaseCustomConstraint): expected_exceptions = (exception.StackValidationFailed,)
[docs] def validate_with_client(self, client, value): conn = client.client(CLIENT_NAME) type_list = conn.policy_types() names = [pt.name for pt in type_list] if value not in names: not_found_message = ( _("Unable to find senlin policy type '%(pt)s', " "available policy types are %(pts)s.") % {'pt': value, 'pts': names} ) raise exception.StackValidationFailed(message=not_found_message)
Creative Commons Attribution 3.0 License

Except where otherwise noted, this document is licensed under Creative Commons Attribution 3.0 License. See all OpenStack Legal Documents.