Source code for heat.engine.clients.client_plugin

#
#    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 abc
import weakref

from keystoneauth1 import exceptions
from keystoneauth1.identity import generic
from keystoneauth1 import plugin
from oslo_config import cfg
from oslo_utils import excutils

import requests
import six

from heat.common import config
from heat.common import exception as heat_exception

cfg.CONF.import_opt('client_retry_limit', 'heat.common.config')


@six.add_metaclass(abc.ABCMeta)
[docs]class ClientPlugin(object): # Module which contains all exceptions classes which the client # may emit exceptions_module = None # supported service types, service like cinder support multiple service # types, so its used in list format service_types = [] # To make the backward compatibility with existing resource plugins default_version = None supported_versions = [] def __init__(self, context): self._context = weakref.ref(context) self._clients = weakref.ref(context.clients) self.invalidate() @property
[docs] def context(self): ctxt = self._context() assert ctxt is not None, "Need a reference to the context" return ctxt
@property
[docs] def clients(self): return self._clients()
_get_client_option = staticmethod(config.get_client_option)
[docs] def invalidate(self): """Invalidate/clear any cached client.""" self._client_instances = {}
[docs] def client(self, version=None): if not version: version = self.default_version if (version in self._client_instances and not self.context.auth_needs_refresh()): return self._client_instances[version] # Back-ward compatibility if version is None: self._client_instances[version] = self._create() else: if version not in self.supported_versions: raise heat_exception.InvalidServiceVersion( version=version, service=self._get_service_name()) self._client_instances[version] = self._create(version=version) return self._client_instances[version]
@abc.abstractmethod def _create(self, version=None): """Return a newly created client.""" pass def _get_region_name(self): return self.context.region_name or cfg.CONF.region_name_for_services
[docs] def url_for(self, **kwargs): keystone_session = self.context.keystone_session def get_endpoint(): return keystone_session.get_endpoint(**kwargs) # NOTE(jamielennox): use the session defined by the keystoneclient # options as traditionally the token was always retrieved from # keystoneclient. try: kwargs.setdefault('interface', kwargs.pop('endpoint_type')) except KeyError: pass kwargs.setdefault('region_name', self._get_region_name()) url = None try: url = get_endpoint() except exceptions.EmptyCatalog: endpoint = keystone_session.get_endpoint( None, interface=plugin.AUTH_INTERFACE) token = keystone_session.get_token(None) token_obj = generic.Token(endpoint, token) auth_ref = token_obj.get_access(keystone_session) if auth_ref.has_service_catalog(): self.context.reload_auth_plugin() url = get_endpoint() # NOTE(jamielennox): raising exception maintains compatibility with # older keystoneclient service catalog searching. if url is None: raise exceptions.EndpointNotFound() return url
[docs] def is_client_exception(self, ex): """Returns True if the current exception comes from the client.""" if self.exceptions_module: if isinstance(self.exceptions_module, list): for m in self.exceptions_module: if type(ex) in six.itervalues(m.__dict__): return True else: return type(ex) in six.itervalues( self.exceptions_module.__dict__) return False
[docs] def is_not_found(self, ex): """Returns True if the exception is a not-found.""" return False
[docs] def is_over_limit(self, ex): """Returns True if the exception is an over-limit.""" return False
[docs] def is_conflict(self, ex): """Returns True if the exception is a conflict.""" return False
@excutils.exception_filter
[docs] def ignore_not_found(self, ex): """Raises the exception unless it is a not-found.""" return self.is_not_found(ex)
@excutils.exception_filter
[docs] def ignore_conflict_and_not_found(self, ex): """Raises the exception unless it is a conflict or not-found.""" return self.is_conflict(ex) or self.is_not_found(ex)
[docs] def does_endpoint_exist(self, service_type, service_name): endpoint_type = self._get_client_option(service_name, 'endpoint_type') try: self.url_for(service_type=service_type, endpoint_type=endpoint_type) return True except exceptions.EndpointNotFound: return False
[docs]def retry_if_connection_err(exception): return isinstance(exception, requests.ConnectionError)
[docs]def retry_if_result_is_false(result): return result is False

Project Source