Sha256: 5619ee7a811cdf76305f5a00132ccdf76a358f47403811d5f30b36e597a26ff9

Contents?: true

Size: 268 Bytes

Versions: 16

Compression:

Stored size: 268 Bytes

Contents

module Marty::Diagnostic; class DelayedJobWorkers < Base
  diagnostic_fn do
    my_ip = Node.my_ip
    count = Node.get_target_connections('delayed').count{
      |ip|
      (ip == my_ip || ip == '127.0.0.1')
    }
    count.zero? ? error(count) : count
  end
end
end

Version data entries

16 entries across 16 versions & 1 rubygems

Version Path
marty-2.1.5 other/marty/diagnostic/delayed_job_workers.rb
marty-2.1.4 other/marty/diagnostic/delayed_job_workers.rb
marty-2.1.3 other/marty/diagnostic/delayed_job_workers.rb
marty-2.1.2 other/marty/diagnostic/delayed_job_workers.rb
marty-2.1.1 other/marty/diagnostic/delayed_job_workers.rb
marty-2.1.0 other/marty/diagnostic/delayed_job_workers.rb
marty-2.0.9 other/marty/diagnostic/delayed_job_workers.rb
marty-2.0.8 other/marty/diagnostic/delayed_job_workers.rb
marty-2.0.7 other/marty/diagnostic/delayed_job_workers.rb
marty-2.0.6 other/marty/diagnostic/delayed_job_workers.rb
marty-2.0.5 other/marty/diagnostic/delayed_job_workers.rb
marty-2.0.4 other/marty/diagnostic/delayed_job_workers.rb
marty-2.0.3 other/marty/diagnostic/delayed_job_workers.rb
marty-2.0.2 other/marty/diagnostic/delayed_job_workers.rb
marty-2.0.1 other/marty/diagnostic/delayed_job_workers.rb
marty-2.0.0 other/marty/diagnostic/delayed_job_workers.rb