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 |