Class: WatchmonkeyCli::Checker

Inherits:
Object
  • Object
show all
Defined in:
lib/watchmonkey_cli/checker.rb

Defined Under Namespace

Modules: AppHelper Classes: Result

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(app) ⇒ Checker

Returns a new instance of Checker.



110
111
112
113
 
# File 'lib/watchmonkey_cli/checker.rb', line 110

def initialize app
  @app = app
  send(:init) if respond_to?(:init)
end

Instance Attribute Details

#app ⇒ Object (readonly) 



108
109
110
 
# File 'lib/watchmonkey_cli/checker.rb', line 108

def app
  @app
end

Class Method Details

.checker_name ⇒ Object 



12
13
14
 
# File 'lib/watchmonkey_cli/checker.rb', line 12

def self.checker_name
  @checker_name || self.name
end

.checker_name=(name) ⇒ Object 



16
17
18
 
# File 'lib/watchmonkey_cli/checker.rb', line 16

def self.checker_name= name
  @checker_name = name
end

.descendants ⇒ Object

Descendant tracking for inherited classes.



4
5
6
 
# File 'lib/watchmonkey_cli/checker.rb', line 4

def self.descendants
  @descendants ||= []
end

.inherited(descendant) ⇒ Object 



8
9
10
 
# File 'lib/watchmonkey_cli/checker.rb', line 8

def self.inherited(descendant)
  descendants << descendant
end

Instance Method Details

#_tolog(msg, meth = :log) ⇒ Object 



141
142
143
144
 
# File 'lib/watchmonkey_cli/checker.rb', line 141

def _tolog msg, meth = :log
  return unless app.opts[:logfile]
  app.logger.public_send(meth, msg)
end

#check!(*a) ⇒ Object

Raises:

  • (NotImplementedError) 


224
225
226
 
# File 'lib/watchmonkey_cli/checker.rb', line 224

def check! *a
  raise NotImplementedError, "a checker (#{self.class.name}) must implement `#check!' method!"
end

#debug(msg, robj = nil) ⇒ Object 



124
125
126
127
128
129
130
131
132
 
# File 'lib/watchmonkey_cli/checker.rb', line 124

def debug msg, robj = nil
  app.fire(:on_debug, msg, robj)
  app.fire(:on_message, msg, robj)
  return if app.opts[:quiet] || app.opts[:silent]
  _tolog(msg, :debug)
  app.sync do
    puts app.c(msg, :black)
  end
end

#error(msg, robj = nil) ⇒ Object 



134
135
136
137
138
139
 
# File 'lib/watchmonkey_cli/checker.rb', line 134

def error msg, robj = nil
  app.fire(:on_error, msg, robj)
  app.fire(:on_message, msg, robj)
  _tolog(msg, :error)
  app.sync { app.error(msg) }
end

#info(msg, robj = nil) ⇒ Object 



115
116
117
118
119
120
121
122
 
# File 'lib/watchmonkey_cli/checker.rb', line 115

def info msg, robj = nil
  app.fire(:on_info, msg, robj)
  return if app.opts[:quiet]
  _tolog(msg, :info)
  app.sync do
    puts app.c(msg, :blue)
  end
end

#init ⇒ Object

API =



206
207
208
 
# File 'lib/watchmonkey_cli/checker.rb', line 206

def init
  # hook method (called when checker is being initialized)
end

#local ⇒ Object

def to_s

string = "#<#{self.class.name}:#{self.object_id} "
fields = self.class.inspector_fields.map{|field| "#{field}: #{self.send(field)}"}
string << fields.join(", ") << ">"

end



159
160
161
 
# File 'lib/watchmonkey_cli/checker.rb', line 159

def local
  @app.fetch_connection(:loopback, :local)
end

#rsafe(resultobj, &block) ⇒ Object 



181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
 
# File 'lib/watchmonkey_cli/checker.rb', line 181

def rsafe resultobj, &block
  tries = 0
  begin
    tries += 1
    block.call
  rescue StandardError => e
    unless tries > 3
      resultobj.sync do
        resultobj.error! "retry #{tries} reason is `#{e.class}: #{e.message}'"
        e.backtrace.each{|l| resultobj.debug "\t\t#{l}" }
        resultobj.dump!
      end
      sleep 1
      retry
    end
    resultobj.error! "#{descriptor}retries exceeded"
    resultobj.dump!
  end
end

#safe(descriptor = nil, &block) ⇒ Object 



163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
 
# File 'lib/watchmonkey_cli/checker.rb', line 163

def safe descriptor = nil, &block
  tries = 0
  begin
    tries += 1
    block.call
  rescue StandardError => e
    unless tries > 3
      app.sync do
        error "#{descriptor}retry #{tries} reason is `#{e.class}: #{e.message}'"
        e.backtrace.each{|l| debug "\t\t#{l}" }
      end
      sleep 1
      retry
    end
    error "#{descriptor}retries exceeded"
  end
end

#spawn_sub(which, *args) ⇒ Object 



146
147
148
149
150
151
 
# File 'lib/watchmonkey_cli/checker.rb', line 146

def spawn_sub which, *args
  return false if app.running?
  if sec = app.checkers["ssl_expiration"]
    sec.enqueue(*args)
  end
end

#start ⇒ Object 



210
211
212
213
 
# File 'lib/watchmonkey_cli/checker.rb', line 210

def start
  # hook method (called after all checkers were initialized and configs + hosts are loaded)
  # can/should be used for starting connections, etc.
end

#stop ⇒ Object 



215
216
217
218
219
220
221
222
 
# File 'lib/watchmonkey_cli/checker.rb', line 215

def stop
  # hook method (called on application shutdown)
  # connections should be closed here

  # DO NOT CLOSE CONNECTIONS HANDLED BY THE APP!
  # Keep in mind that the checkers run concurrently
  # and therefore shared resources might still be in use
end