X-Git-Url: https://review.fuel-infra.org/gitweb?a=blobdiff_plain;f=plugins%2Fmcollective%2Faggregate%2Faverage.rb;fp=plugins%2Fmcollective%2Faggregate%2Faverage.rb;h=5e56d2e105e94af6e17fdfe8aa95fa96f434fefb;hb=b87d2f4e68281062df1913440ca5753ae63314a9;hp=0000000000000000000000000000000000000000;hpb=ab0ea530b8ac956091f17b104ab2311336cfc250;p=packages%2Fprecise%2Fmcollective.git

diff --git a/plugins/mcollective/aggregate/average.rb b/plugins/mcollective/aggregate/average.rb
new file mode 100644
index 0000000..5e56d2e
--- /dev/null
+++ b/plugins/mcollective/aggregate/average.rb
@@ -0,0 +1,29 @@
+module MCollective
+  class Aggregate
+    class Average<Base
+      # Before function is run processing
+      def startup_hook
+        @result[:value] = 0
+        @result[:type] = :numeric
+
+        @count = 0
+
+        # Set default aggregate_function if it is undefined
+        @aggregate_format = "Average of #{@result[:output]}: %f" unless @aggregate_format
+      end
+
+      # Determines the average of a set of numerical values
+      def process_result(value, reply)
+        @result[:value] += value
+        @count += 1
+      end
+
+      # Stops execution of the function and returns a ResultObject
+      def summarize
+        @result[:value] /= @count
+
+        result_class(:numeric).new(@result, @aggregate_format, @action)
+      end
+    end
+  end
+end