¡@

Home 

OpenStack Study: api.py

OpenStack Index

**** CubicPower OpenStack Study ****

def configure_registry_client():

    """

    Sets up a registry client for use in registry lookups

    """

    global _CLIENT_KWARGS, _CLIENT_HOST, _CLIENT_PORT

    try:

        host, port = CONF.registry_host, CONF.registry_port

    except cfg.ConfigFileValueError:

        msg = _("Configuration option was not valid")

        LOG.error(msg)

        raise exception.BadRegistryConnectionConfiguration(msg)

    except IndexError:

        msg = _("Could not find required configuration option")

        LOG.error(msg)

        raise exception.BadRegistryConnectionConfiguration(msg)

    _CLIENT_HOST = host

    _CLIENT_PORT = port

    _CLIENT_KWARGS = {

        'use_ssl': CONF.registry_client_protocol.lower() == 'https',

        'key_file': CONF.registry_client_key_file,

        'cert_file': CONF.registry_client_cert_file,

        'ca_file': CONF.registry_client_ca_file,

        'insecure': CONF.registry_client_insecure,

        'timeout': CONF.registry_client_timeout,

    }

    if not CONF.use_user_token:

        configure_registry_admin_creds()

**** CubicPower OpenStack Study ****

def configure_registry_admin_creds():

    global _CLIENT_CREDS

    if CONF.auth_url or os.getenv('OS_AUTH_URL'):

        strategy = 'keystone'

    else:

        strategy = CONF.auth_strategy

    _CLIENT_CREDS = {

        'user': CONF.admin_user,

        'password': CONF.admin_password,

        'username': CONF.admin_user,

        'tenant': CONF.admin_tenant_name,

        'auth_url': CONF.auth_url,

        'strategy': strategy,

        'region': CONF.auth_region,

    }

**** CubicPower OpenStack Study ****

def get_registry_client(cxt):

    global _CLIENT_CREDS, _CLIENT_KWARGS, _CLIENT_HOST, _CLIENT_PORT

    kwargs = _CLIENT_KWARGS.copy()

    if CONF.use_user_token:

        kwargs['auth_tok'] = cxt.auth_tok

    if _CLIENT_CREDS:

        kwargs['creds'] = _CLIENT_CREDS

    return client.RegistryClient(_CLIENT_HOST, _CLIENT_PORT, **kwargs)