Skip to content
Snippets Groups Projects
Commit c426007d authored by Bjarke Madsen's avatar Bjarke Madsen
Browse files

POL1-898: Unify logic for selecting interface between poller-udf and brian-dashboard-manager

parent 7ea0e952
Branches
Tags
No related merge requests found
...@@ -24,6 +24,18 @@ PANEL_WIDTH = 24 ...@@ -24,6 +24,18 @@ PANEL_WIDTH = 24
logger = logging.getLogger(__file__) logger = logging.getLogger(__file__)
def endpoint_sort_key(endpoint):
# sort by equipment/port if exists, otherwise host/interface
if 'equipment' in endpoint:
equipment = endpoint['equipment']
port = endpoint['port']
return equipment, port
else:
hostname = endpoint['hostname']
interface = endpoint['interface']
return hostname, interface
def num_generator(start=30): def num_generator(start=30):
""" """
Generator for numbers starting from the value of `start` Generator for numbers starting from the value of `start`
...@@ -223,7 +235,7 @@ def get_re_peer_interface_data(interfaces): ...@@ -223,7 +235,7 @@ def get_re_peer_interface_data(interfaces):
def get_service_aggregate_targets(services): def get_service_aggregate_targets(services):
for service in services: for service in services:
_interfaces = service.get('endpoints') _interfaces = sorted(service.get('endpoints', []), key=endpoint_sort_key)
name = service.get('name') name = service.get('name')
sid = service.get('sid') sid = service.get('sid')
scid = service.get('scid') scid = service.get('scid')
...@@ -309,7 +321,7 @@ def get_nren_interface_data(services, interfaces, excluded_dashboards, region_cu ...@@ -309,7 +321,7 @@ def get_nren_interface_data(services, interfaces, excluded_dashboards, region_cu
dashboard['AGGREGATES'].append(target) dashboard['AGGREGATES'].append(target)
for service in services: for service in services:
_interfaces = service.get('endpoints') _interfaces = sorted(service.get('endpoints', []), key=endpoint_sort_key)
name = service.get('name') name = service.get('name')
sid = service.get('sid') sid = service.get('sid')
scid = service.get('scid') scid = service.get('scid')
...@@ -450,7 +462,7 @@ def get_service_data(service_type, services, interfaces, excluded_dashboards): ...@@ -450,7 +462,7 @@ def get_service_data(service_type, services, interfaces, excluded_dashboards):
}) })
for service in services: for service in services:
_interfaces = service.get('endpoints') _interfaces = sorted(service.get('endpoints', []), key=endpoint_sort_key)
name = service.get('name') name = service.get('name')
sid = service.get('sid') sid = service.get('sid')
scid = service.get('scid') scid = service.get('scid')
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment