[lib] kwollect - populate clusters network metrics from network devices metrics content

lib/refrepo/gen/puppet/templates/kwollect-network.erb

@@ -12,7 +12,6 @@ neteq.fetch('metrics', []).each {|metric|
         next if lport.empty?
         port_uid = neteq['linecards'].length > 1 ? "#{linecard_uid}_#{lport_uid}" : lport_uid
         port_name = lport['snmp_name']
-        # TODO: Handle secondary interface
         port_node = lport['uid']
         labels = lport['kind'] == 'node' ? {'interface': lport['port']} : {}
         labels.update({'_device_alias': port_node})

lib/refrepo/input_loader.rb

@@ -60,6 +60,9 @@ def load_yaml_file_hierarchy(directory = File.expand_path("../../input/grid5000/
   # populate each node with software informations
   add_software(global_hash)
 
+  # populate each cluster with metrics network information
+  add_network_metrics(global_hash)
+
   return global_hash
 end
 
@@ -221,3 +224,35 @@ def add_software(h)
     end
   end
 end
+
+def add_network_metrics(h)
+  # for each cluster
+  h['sites'].each_pair do |site_uid, site|
+    site['clusters'].each_pair do |cluster_uid, cluster|
+
+      # remove any network metrics defined in cluster
+      cluster['metrics'] = cluster.fetch('metrics', []).reject {|m| m['name'] =~ /network_.*_bytes_total/}
+
+      # for each interface of a cluster's node
+      node_uid, node = cluster['nodes'].first
+      node["network_adapters"].each do |iface_uid, iface|
+
+        # get switch attached to interface
+        if iface['mounted'] and not iface['management'] and iface['interface'] == 'Ethernet'
+          switch, _ = net_switch_port_lookup(site, node_uid, iface_uid) || net_switch_port_lookup(site, node_uid)
+        else
+          switch, _ = net_switch_port_lookup(site, node_uid, iface_uid)
+        end
+
+        # for each network metric declared for the switch
+        site.fetch('networks', {}).fetch(switch, {}).fetch('metrics', []).select{|m| m['name'] =~ /network_.*_bytes_total/}.each do |metric|
+
+          # add this metric to cluster's list of available metrics, associated to node interface
+          cluster['metrics'].push(metric.merge(
+            {"labels": {"interface": iface_uid}, "source": {"protocol": "network_equipment"}}
+          ))
+        end
+      end
+    end
+  end
+end