Sha256: acd4c91a44206efc2903dcb766ce34942a92bb75d0856b8dfdfbce122516b7d9

Contents?: true

Size: 351 Bytes

Versions: 8

Compression:

Stored size: 351 Bytes

Contents

module JstdRunner
  module Monitorable
    def monitor(interval, &failure_callback)
      EM.add_periodic_timer(interval) {
        next if JstdRunner.shutting_down || @restarting
        if running?
          Log.info "ok: #{self}"
        else
          Log.info "dead: #{self}"
          failure_callback.call
        end
      }
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
jstd-runner-0.0.9 lib/jstd-runner/monitorable.rb
jstd-runner-0.0.8 lib/jstd-runner/monitorable.rb
jstd-runner-0.0.7 lib/jstd-runner/monitorable.rb
jstd-runner-0.0.6 lib/jstd-runner/monitorable.rb
jstd-runner-0.0.5 lib/jstd-runner/monitorable.rb
jstd-runner-0.0.4 lib/jstd-runner/monitorable.rb
jstd-runner-0.0.3 lib/jstd-runner/monitorable.rb
jstd-runner-0.0.2 lib/jstd-runner/monitorable.rb