From 666ea91e473554acabe6f6c3477eb915e70a7538 Mon Sep 17 00:00:00 2001 From: Nat Lasseter Date: Mon, 16 Mar 2020 10:15:21 +0000 Subject: Refactor: renamed jobs to raiders, becaus pun, and jobs is confusing given the intended application of longboat by the original authors. --- lib/longboat/jobs.rb | 49 ------------------------------------------------- 1 file changed, 49 deletions(-) delete mode 100644 lib/longboat/jobs.rb (limited to 'lib/longboat/jobs.rb') diff --git a/lib/longboat/jobs.rb b/lib/longboat/jobs.rb deleted file mode 100644 index 5166993..0000000 --- a/lib/longboat/jobs.rb +++ /dev/null @@ -1,49 +0,0 @@ -module Longboat - class Jobs - def initialize(collector, config) - @collector = collector - @jobs = [] - @config = config - - @config[:jobs_path].each do |dir| - next unless Dir.exist?(dir) - - Dir.entries(dir).each do |file| - next if file =~ /^\./ - - reqname = File.basename(file, ".rb") - cname = reqname.split('_').map(&:capitalize).join - - require "jobs/#{reqname}" - @jobs << Kernel.const_get(cname).new(@collector, job_config) - end - end - end - - def collect! - @jobs.each(&:run) - end - - def collect_every(time = @config[:collect_every], async = true) - if async - Thread.new do - loop do - collect! - sleep(time) - end - end - else - loop do - collect! - sleep(time) - end - end - end - - private - - def job_config - @config.slice(:collect_every, :metric_prefix) - end - end -end -- cgit v1.2.1