def wait_till_commondb_is_ready(config, process_name="osm-mon", commondb_wait_time=5):
-
logging.debug("wait_till_commondb_is_ready")
while True:
def wait_till_kafka_is_ready(config, process_name="osm-mon", kafka_wait_time=5):
-
logging.debug("wait_till_kafka_is_ready")
while True:
def wait_till_core_services_are_ready(
config, process_name="osm-mon", commondb_wait_time=5, kafka_wait_time=5
):
-
logging.debug("wait_till_core_services_are_ready")
if not config:
return resource_list
def get_metrics(self, vdu_mappings={}, monitoring_params={}, vnfr=None, tags={}):
-
monitoring_keys = {}
# Collect the names of all the metrics we need to query
for metric_entry in monitoring_params:
vdu_mappings = sanitized_vdu_mappings
try:
-
# Now we can make a single call to vROPS to collect all relevant metrics for resources we need to monitor
api_url = (
"/suite-api/api/resources/stats?IntervalType=MINUTES&IntervalCount=1"
async def _process_msg(self, topic, key, values):
log.info("Message arrived: %s", values)
try:
-
if topic == "alarm_request":
if key == "create_alarm_request":
alarm_details = values["alarm_create_request"]
super().tearDown()
def test_collect_cpu_and_memory(self, mock_vm_moref_id):
-
mock_vm_moref_id.return_value = "VMWARE-OID-VM-1"
self.vnfd["vdu"][0]["monitoring-parameter"] = [
{"id": "ubuntu_vnf_cpu_util", "performance-metric": "cpu_utilization"},