Source code for rackspace.clients

#
#    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 oslo.config import cfg

from heat.common import exception
from heat.engine import clients
from heat.openstack.common.gettextutils import _
from heat.openstack.common import log as logging

logger = logging.getLogger(__name__)

try:
    import pyrax
except ImportError:
    logger.info(_('pyrax not available'))

try:
    from swiftclient import client as swiftclient
except ImportError:
    swiftclient = None
    logger.info(_('swiftclient not available'))
try:
    from ceilometerclient import client as ceilometerclient
except ImportError:
    ceilometerclient = None
    logger.info(_('ceilometerclient not available'))

cloud_opts = [
    cfg.StrOpt('region_name',
               default=None,
               help=_('Region for connecting to services.'))
]
cfg.CONF.register_opts(cloud_opts)


class Clients(clients.OpenStackClients):
[docs] ''' Convenience class to create and cache client instances. ''' def __init__(self, context): super(Clients, self).__init__(context) self.pyrax = None def _get_client(self, name): if not self.pyrax: self.__authenticate() return self.pyrax.get(name) def auto_scale(self):
[docs] """Rackspace Auto Scale client.""" return self._get_client("autoscale") def cloud_db(self):
[docs] '''Rackspace cloud database client.''' return self._get_client("database") def cloud_lb(self):
[docs] '''Rackspace cloud loadbalancer client.''' return self._get_client("load_balancer") def cloud_dns(self):
[docs] '''Rackspace cloud dns client.''' return self._get_client("dns") def nova(self, service_type="compute"):
[docs] '''Rackspace cloudservers client. Specifying the service type is to maintain compatibility with clients.OpenStackClients. It is not actually a valid option to change within pyrax. ''' if service_type is not "compute": raise ValueError(_("service_type should be compute.")) return self._get_client(service_type) def cloud_networks(self):
[docs] '''Rackspace cloud networks client.''' return self._get_client("network") def trove(self):
[docs] '''Rackspace trove client.''' if not self._trove: super(Clients, self).trove(service_type='rax:database') management_url = self.url_for(service_type='rax:database', region_name=cfg.CONF.region_name) self._trove.client.management_url = management_url return self._trove def cinder(self):
[docs] """Override the region for the cinder client.""" if not self._cinder: super(Clients, self).cinder() management_url = self.url_for(service_type='volume', region_name=cfg.CONF.region_name) self._cinder.client.management_url = management_url return self._cinder def __authenticate(self):
pyrax.set_setting("identity_type", "keystone") pyrax.set_setting("auth_endpoint", self.context.auth_url) logger.info(_("Authenticating username:%s") % self.context.username) self.pyrax = pyrax.auth_with_token(self.context.auth_token, tenant_id=self.context.tenant_id, tenant_name=self.context.tenant, region=(cfg.CONF.region_name or None)) if not self.pyrax: raise exception.AuthorizationFailure("No services available.") logger.info(_("User %s authenticated successfully.") % self.context.username)