Remove api_servers references

cyborg thankfully did not import the api_servers config option from
nova. That's awesome, because it's going away anyway.

This is step one in a set of patches to improve glance interactions
by increasing use of sdk. By itself it should be completely no-op.

Change-Id: I87d38acb350b03d735ba1e5d4f79b6fbbea4314e
This commit is contained in:
Monty Taylor 2020-06-18 11:28:24 -05:00
parent 9915d7a5f7
commit 8826575689
2 changed files with 12 additions and 15 deletions

View File

@ -56,8 +56,10 @@ class API(object):
:param image_ref: The image ref to generate URL
:param context: The `cyborg.context.Context` object for the request
"""
return "%s/images/%s" % (next(glance.get_api_servers(context)),
image_ref)
return "%s/images/%s" % (
glance.get_api_server(context),
image_ref,
)
def get_all(self, context, **kwargs):
"""Retrieves all information records about all acclerator images

View File

@ -17,7 +17,6 @@
import copy
import inspect
import itertools
import os
import re
import stat
@ -75,8 +74,8 @@ def _glanceclient_from_endpoint(context, endpoint, version):
def generate_glance_url(context):
"""Return a random glance url from the api servers we know about."""
return next(get_api_servers(context))
"""Return the glance url."""
return get_api_server(context)
def _endpoint_from_image_ref(image_href):
@ -103,10 +102,8 @@ def generate_identity_headers(context, status='Confirmed'):
}
def get_api_servers(context):
"""Get a list of service endpoints and return an iterator that will
cycle through the list, looping around to the beginning if necessary.
"""
def get_api_server(context):
"""Get the service endpoint."""
sess, auth = _session_and_auth(context)
ksa_adap = utils.get_ksa_adapter(
cyborg.conf.glance.DEFAULT_SERVICE_TYPE,
@ -119,9 +116,8 @@ def get_api_servers(context):
# We can't use glanceclient.common.utils.strip_version because
# of bug 1748009.
endpoint = re.sub(r'/v\d+(\.\d+)?/?$', '/', endpoint)
api_servers = [endpoint]
return itertools.cycle(api_servers)
return endpoint
class GlanceClientWrapper(object):
@ -135,7 +131,7 @@ class GlanceClientWrapper(object):
version)
else:
self.client = None
self.api_servers = None
self.api_server = None
def _create_static_client(self, context, endpoint, version):
"""Create a client that we'll use for every call."""
@ -144,9 +140,8 @@ class GlanceClientWrapper(object):
def _create_onetime_client(self, context, version):
"""Create a client that will be used for one call."""
if self.api_servers is None:
self.api_servers = get_api_servers(context)
self.api_server = next(self.api_servers)
if self.api_server is None:
self.api_server = get_api_server(context)
return _glanceclient_from_endpoint(context, self.api_server, version)
def call(self, context, version, method, *args, **kwargs):