Module: Komrade

Extended by:
Komrade
Included in:
Komrade
Defined in:
lib/komrade-client.rb,
lib/komrade-client/queue.rb,
lib/komrade-client/worker.rb,
lib/komrade-client/railtie.rb,
lib/komrade-client/http_helpers.rb,
lib/komrade-client/rate_limiter.rb

Defined Under Namespace

Modules: HttpHelpers, Queue, RateLimiter Classes: Railtie, Worker

Constant Summary collapse

Error = 
Class.new(StandardError)

Instance Method Summary collapse

Instance Method Details

#env(key) ⇒ Object 



9
10
11
 
# File 'lib/komrade-client.rb', line 9

def env(key)
  ENV[key]
end

#env!(key) ⇒ Object 



13
14
15
 
# File 'lib/komrade-client.rb', line 13

def env!(key)
  env(key) || raise(Error, "Komrade requires #{key} be set in the ENV.")
end

#log(data) ⇒ Object 



21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/komrade-client.rb', line 21

def log(data)
  data.merge!(:lib => 'komrade-client')
  result = nil
  if data.key?(:measure)
    data[:measure].insert(0, "komrade.")
  end
  if block_given?
    start = Time.now
    result = yield
    data.merge!(:val => (Time.now - start))
  end
  data.reduce(out=String.new) do |s, tup|
    s << [tup.first, tup.last].join("=") << " "
  end
  @outLocker.synchronize do
    $stdout.puts(out)
  end
  return result
end

#url ⇒ Object 



17
18
19
 
# File 'lib/komrade-client.rb', line 17

def url
  URI.parse(env!("KOMRADE_URL"))
end