(prom_addresses, timeout=None)
| 461 | |
| 462 | |
| 463 | def fetch_prometheus(prom_addresses, timeout=None): |
| 464 | components_dict = {} |
| 465 | metric_descriptors = {} |
| 466 | metric_samples = [] |
| 467 | |
| 468 | for address in prom_addresses: |
| 469 | if address not in components_dict: |
| 470 | components_dict[address] = set() |
| 471 | |
| 472 | for address, response in fetch_raw_prometheus(prom_addresses, timeout=timeout): |
| 473 | for metric in text_string_to_metric_families(response): |
| 474 | for sample in metric.samples: |
| 475 | metric_descriptors[sample.name] = metric |
| 476 | metric_samples.append(sample) |
| 477 | if "Component" in sample.labels: |
| 478 | components_dict[address].add(sample.labels["Component"]) |
| 479 | return components_dict, metric_descriptors, metric_samples |
| 480 | |
| 481 | |
| 482 | def fetch_prometheus_timeseries( |
no test coverage detected
searching dependent graphs…