Sha256: 9abee37fc3bd57aba0cd7ed3f494f72d9605c2280ec23a10bde7477c2ac2dba2
Contents?: true
Size: 1.8 KB
Versions: 18
Compression:
Stored size: 1.8 KB
Contents
module Bluepill
class ConditionWatch
attr_accessor :logger, :name
EMPTY_ARRAY = [].freeze # no need to recreate one every tick
def initialize(name, options = {})
@name = name
@logger = options.delete(:logger)
@fires = options.has_key?(:fires) ? Array(options.delete(:fires)) : [:restart]
@every = options.delete(:every)
@times = options[:times] || [1,1]
@times = [@times, @times] unless @times.is_a?(Array) # handles :times => 5
self.clear_history!
@process_condition = ProcessConditions[@name].new(options)
end
def run(pid, tick_number = Time.now.to_i)
if @last_ran_at.nil? || (@last_ran_at + @every) <= tick_number
@last_ran_at = tick_number
self.record_value(@process_condition.run(pid))
return @fires if self.fired?
end
EMPTY_ARRAY
end
def record_value(value)
# TODO: record value in ProcessStatistics
@history[@history_index] = [value, @process_condition.check(value)]
@history_index = (@history_index + 1) % @history.size
self.logger.info(self.to_s)
end
def clear_history!
@last_ran_at = nil
@history = Array.new(@times[1])
@history_index = 0
end
def fired?
@history.select {|v| v && !v[1]}.size >= @times[0]
end
def to_s
# TODO: this will be out of order because of the way history values are assigned
# use (@history[(@history_index - 1)..1] + @history[0..(@history_index - 1)]).
# collect {|v| "#{v[0]}#{v[1] ? '' : '*'}"}.join(", ")
# but that's gross so... it's gonna be out of order till we figure out a better way to get it in order
data = @history.collect {|v| "#{v[0]}#{v[1] ? '' : '*'}" if v}.compact.join(", ")
"#{@name}: [#{data}]"
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems