Sha256: eab8c3201cce95177d8b1bba7adc1aaf631c55cb0ae1389ff4e82462facab9b2
Contents?: true
Size: 733 Bytes
Versions: 20
Compression:
Stored size: 733 Bytes
Contents
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"
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
Version data entries
20 entries across 20 versions & 1 rubygems