pass all flow sensors to sflow pipeline

resources/libraries/get_all_flow_sensors_info.rb

@@ -0,0 +1,19 @@
+module Rb_manager
+  module Helpers
+    def get_all_flow_sensors_info()
+      sensors_info = {}
+      sensor_types = ["flow-sensor"]
+
+      sensor_types.each do |s_type|
+        sensors = search(:node, "role:#{s_type}").sort
+
+        sensors_info[s_type] = []
+        sensors.each do |s|
+          sensors_info[s_type] << s
+        end
+      end
+      sensors_info
+    end
+  end
+end
+

resources/recipes/configure.rb

@@ -276,7 +276,7 @@
 
 logstash_config "Configure logstash" do
   cdomain node["redborder"]["cdomain"]
-  flow_nodes node["redborder"]["sensors_info_all"]["flow-sensor"]
+  flow_nodes node["redborder"]["all_flow_sensors_info"]["flow-sensor"]
   namespaces node["redborder"]["namespaces"]
   vault_nodes node["redborder"]["sensors_info_all"]["vault-sensor"]
   scanner_nodes node["redborder"]["sensors_info_all"]["scanner-sensor"]

resources/recipes/prepare_system.rb

@@ -91,6 +91,9 @@
 #get sensors info full info
 node.default["redborder"]["sensors_info_all"] = get_sensors_all_info()
 
+#get sensors info of all flow sensors
+node.default["redborder"]["all_flow_sensors_info"] = get_all_flow_sensors_info()
+
 #get namespaces
 node.default["redborder"]["namespaces"] = get_namespaces