# Copyright 2016 RIFT.IO Inc
#
# Licensed under the Apache License, Version 2.0 (the "License");
# Copyright 2016 RIFT.IO Inc
#
# Licensed under the Apache License, Version 2.0 (the "License");
gi.require_version('RwDtsYang', '1.0')
from gi.repository import (
RwNsrYang,
NsrYang,
gi.require_version('RwDtsYang', '1.0')
from gi.repository import (
RwNsrYang,
NsrYang,
-ScalingCriteria = NsdYang.YangData_Nsd_NsdCatalog_Nsd_ScalingGroupDescriptor_ScalingPolicy_ScalingCriteria
-ScalingPolicy = NsdYang.YangData_Nsd_NsdCatalog_Nsd_ScalingGroupDescriptor_ScalingPolicy
+ScalingCriteria = NsdYang.YangData_RwProject_Project_NsdCatalog_Nsd_ScalingGroupDescriptor_ScalingPolicy_ScalingCriteria
+ScalingPolicy = NsdYang.YangData_RwProject_Project_NsdCatalog_Nsd_ScalingGroupDescriptor_ScalingPolicy
def __init__(self, aggregation_type="AVERAGE", legacy=False):
self.aggregation_type = aggregation_type
self.legacy = legacy
def __init__(self, aggregation_type="AVERAGE", legacy=False):
self.aggregation_type = aggregation_type
self.legacy = legacy
- mock_vnfr = RwVnfrYang.YangData_Vnfr_VnfrCatalog_Vnfr.from_dict({'id': '1'})
- mock_vnfr.vnfd = VnfrYang.YangData_Vnfr_VnfrCatalog_Vnfr_Vnfd.from_dict({'id': '1'})
+ mock_vnfr = RwVnfrYang.YangData_RwProject_Project_VnfrCatalog_Vnfr.from_dict({'id': '1'})
+ mock_vnfr.vnfd = VnfrYang.YangData_RwProject_Project_VnfrCatalog_Vnfr_Vnfd.from_dict({'id': '1'})
'monitoring_param': (monp_cfg if not self.legacy else []),
'constituent_vnfd': [{'member_vnf_index': 1,
'start_by_default': True,
'monitoring_param': (monp_cfg if not self.legacy else []),
'constituent_vnfd': [{'member_vnf_index': 1,
'start_by_default': True,
def _populate_mock_values(self, criterias, nsr_id, floor, ceil):
# Mock publish
# Verify Scale in AND operator
def _populate_mock_values(self, criterias, nsr_id, floor, ceil):
# Mock publish
# Verify Scale in AND operator
publisher = rift.test.dts.DescriptorPublisher(self.log, self.dts, self.loop)
for criteria in criterias:
monp_id = criteria.ns_monitoring_param_ref
publisher = rift.test.dts.DescriptorPublisher(self.log, self.dts, self.loop)
for criteria in criterias:
monp_id = criteria.ns_monitoring_param_ref
- w_xpath = "D,/nsr:ns-instance-opdata/nsr:nsr"
- w_xpath = w_xpath + "[nsr:ns-instance-config-ref='{}']/nsr:monitoring-param".format(nsr_id)
- xpath = w_xpath + "[nsr:id ='{}']".format(monp_id)
+ w_xpath = "D,/rw-project:project/nsr:ns-instance-opdata/nsr:nsr"
+ w_xpath = w_xpath + "[nsr:ns-instance-config-ref={}]/nsr:monitoring-param".format(quoted_key(nsr_id))
+ xpath = w_xpath + "[nsr:id={}]".format(quoted_key(monp_id))
value = random.randint(floor, ceil)
monp = NsMonParam.from_dict({
value = random.randint(floor, ceil)
monp = NsMonParam.from_dict({
yield from self._populate_mock_values(policy.scaling_criteria, nsr_id, floor, ceil)
assert mock_delegate.scale_in_called == 0
yield from self._populate_mock_values(policy.scaling_criteria, nsr_id, floor, ceil)
assert mock_delegate.scale_in_called == 0
yield from scale_out(policy)
yield from self._populate_mock_values(policy.scaling_criteria, nsr_id, floor, ceil)
assert mock_delegate.scale_in_called == 1
yield from scale_out(policy)
yield from self._populate_mock_values(policy.scaling_criteria, nsr_id, floor, ceil)
assert mock_delegate.scale_in_called == 1
runner = xmlrunner.XMLTestRunner(output=os.environ["RIFT_MODULE_TEST"])
parser = argparse.ArgumentParser()
runner = xmlrunner.XMLTestRunner(output=os.environ["RIFT_MODULE_TEST"])
parser = argparse.ArgumentParser()