class MonParamMsgGenerator(object):
def __init__(self, num_messages=1):
ping_path = r"/api/v1/ping/stats"
class MonParamMsgGenerator(object):
def __init__(self, num_messages=1):
ping_path = r"/api/v1/ping/stats"
self._mon_param_msgs = []
for i in range(1, num_messages):
self._mon_param_msgs = []
for i in range(1, num_messages):
'id': '%s' % i,
'name': 'param_num_%s' % i,
'json_query_method': "NAMEKEY",
'id': '%s' % i,
'name': 'param_num_%s' % i,
'json_query_method': "NAMEKEY",
def setup_mock_store(self, aggregation_type, monps, legacy=False):
store = mock.MagicMock()
def setup_mock_store(self, aggregation_type, monps, legacy=False):
store = mock.MagicMock()
'ns_instance_config_ref': "1",
'name_ref': "Foo",
'constituent_vnfr_ref': [{'vnfr_id': mock_vnfr.id}],
'ns_instance_config_ref': "1",
'name_ref': "Foo",
'constituent_vnfr_ref': [{'vnfr_id': mock_vnfr.id}],
yield from self._test_publish("COUNT", 2)
@rift.test.dts.async_test
yield from self._test_publish("COUNT", 2)
@rift.test.dts.async_test