Check manager status for policy using passthough healthcheck api

Change-Id: I27641f1b6b171d31778247f8ff49a7130e3ca403
This commit is contained in:
Adit Sarfaty 2019-04-22 09:32:22 +03:00
parent 5875f0d48f
commit 44d0cb5e0f

View File

@ -20,6 +20,7 @@ from oslo_log import log
from vmware_nsxlib import v3 from vmware_nsxlib import v3
from vmware_nsxlib.v3 import client from vmware_nsxlib.v3 import client
from vmware_nsxlib.v3 import exceptions
from vmware_nsxlib.v3 import lib from vmware_nsxlib.v3 import lib
from vmware_nsxlib.v3 import nsx_constants from vmware_nsxlib.v3 import nsx_constants
@ -119,8 +120,24 @@ class NsxPolicyLib(lib.NsxLibBase):
@property @property
def validate_connection_method(self): def validate_connection_method(self):
# TODO(asarfaty): Find an equivalent api to check policy status """Return a method that will validate the NSX manager status"""
pass def check_manager_status_passthrough(client, manager_url):
# Try to get the status silently and with no retries
status = client.get('reverse-proxy/node/health',
silent=True, with_retries=False)
if (not status or not status.get('healthy', False)):
msg = _("Manager is not in working state: %s") % status
LOG.warning(msg)
raise exceptions.ResourceNotFound(
manager=manager_url, operation=msg)
def check_manager_status(client, manager_url):
# Decide on the healthcheck by the passthrough status
if self.nsx_api:
return check_manager_status_passthrough(
self.nsx_api.client, manager_url)
return check_manager_status
def get_version(self): def get_version(self):
"""Get the NSX Policy manager version """Get the NSX Policy manager version