Module: Oboe::Inst::TyphoeusHydraRunnable

Defined in:
lib/oboe/inst/typhoeus.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(klass) ⇒ Object 



74
75
76
 
# File 'lib/oboe/inst/typhoeus.rb', line 74

def self.included(klass)
  ::Oboe::Util.method_alias(klass, :run, ::Typhoeus::Hydra)
end

Instance Method Details

#run_with_oboe ⇒ Object 



78
79
80
81
82
83
84
85
86
87
88
89
90
 
# File 'lib/oboe/inst/typhoeus.rb', line 78

def run_with_oboe
  kvs = {}

  kvs[:queued_requests] = queued_requests.count
  kvs[:max_concurrency] = max_concurrency

  # FIXME: Until we figure out a strategy to deal with libcurl internal
  # threading and Ethon's use of easy handles, here we just do a simple
  # trace of the hydra run.
  Oboe::API.trace("typhoeus_hydra", kvs) do
    run_without_oboe
  end
end