NSXv3: Update stats api
NSXv3 backend has a limitation that it only supports realtime mode for now. This patch adds a source param for stats api. Change-Id: I56a8ad0bb3641c9560cffdb1efcf3b8a7c461580
This commit is contained in:
parent
abc121b5d9
commit
51c3a3a905
@ -535,7 +535,8 @@ class TestService(nsxlib_testcase.NsxClientTestCase):
|
|||||||
fake_service = consts.FAKE_SERVICE.copy()
|
fake_service = consts.FAKE_SERVICE.copy()
|
||||||
self.nsxlib.load_balancer.service.get_stats(fake_service['id'])
|
self.nsxlib.load_balancer.service.get_stats(fake_service['id'])
|
||||||
get.assert_called_with(
|
get.assert_called_with(
|
||||||
'loadbalancer/services/%s/statistics' % fake_service['id'])
|
'loadbalancer/services/%s/statistics?source=realtime' %
|
||||||
|
fake_service['id'])
|
||||||
|
|
||||||
def test_get_status(self):
|
def test_get_status(self):
|
||||||
with mock.patch.object(self.nsxlib.client, 'get') as get:
|
with mock.patch.object(self.nsxlib.client, 'get') as get:
|
||||||
|
@ -386,8 +386,9 @@ class Service(LoadBalancerBase):
|
|||||||
object_url = '%s/%s/%s' % (self.resource, service_id, 'status')
|
object_url = '%s/%s/%s' % (self.resource, service_id, 'status')
|
||||||
return self.client.get(object_url)
|
return self.client.get(object_url)
|
||||||
|
|
||||||
def get_stats(self, service_id):
|
def get_stats(self, service_id, source='realtime'):
|
||||||
object_url = '%s/%s/%s' % (self.resource, service_id, 'statistics')
|
object_url = '%s/%s/%s?source=%s' % (self.resource, service_id,
|
||||||
|
'statistics', source)
|
||||||
return self.client.get(object_url)
|
return self.client.get(object_url)
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user