Sha256: a12227cc3e6ec86061d8ad0e6b05ae4bbab16951ef68059708961059610cb779
Contents?: true
Size: 1.72 KB
Versions: 7
Compression:
Stored size: 1.72 KB
Contents
module Eye::Process::Watchers def add_watchers(force = false) return unless self.up? remove_watchers if force if @watchers.blank? # default watcher :check_alive add_watcher(:check_alive, self[:check_alive_period]) do check_alive end # monitor childs pids if self[:monitor_children] add_watcher(:check_childs, self[:childs_update_period]) do add_or_update_childs end end # monitor conditional watchers start_checkers else warn 'try add_watchers, but its already here' end end def remove_watchers @watchers.each{|_, h| h[:timer].cancel } @watchers = {} end private def add_watcher(type, period = 2, subject = nil, &block) return if @watchers[type] debug "add watcher #{type}(#{period})" timer = every(period.to_f) do debug "check #{type}" block.call(subject) end @watchers[type] ||= {:timer => timer, :subject => subject} end def start_checkers self[:checks].each{|name, cfg| start_checker(name, cfg) } end def start_checker(name, cfg) subject = Eye::Checker.create(pid, cfg, current_actor) # ex: {:type => :memory, :every => 5.seconds, :below => 100.megabytes, :times => [3,5]} add_watcher("check_#{name}".to_sym, subject.every, subject, &method(:watcher_tick).to_proc) if subject end def watcher_tick(subject) unless subject.check return unless up? actions = subject.fires ? Array(subject.fires) : [:restart] notify :warn, "Bounded #{subject.check_name}: #{subject.last_human_values} send to #{actions}" actions.each do |action| schedule action, Eye::Reason.new("bounded #{subject.check_name}") end end end end
Version data entries
7 entries across 7 versions & 2 rubygems