module Oboe::Inst::TyphoeusHydraRunnable

Public Class Methods

included(klass) click to toggle source
# File lib/oboe/inst/typhoeus.rb, line 74
def self.included(klass)
  ::Oboe::Util.method_alias(klass, :run, ::Typhoeus::Hydra)
end

Public Instance Methods

run_with_oboe() click to toggle source
# 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