Sha256: d6934b81f4b9c72b76083454c84c84174801cfc00507efb8cbccf42bcc410efa
Contents?: true
Size: 1.71 KB
Versions: 49
Compression:
Stored size: 1.71 KB
Contents
require 'minitest_helper'
describe Oboe::Inst::Resque do
before do
clear_all_traces
# These are standard entry/exit KVs that are passed up with all moped operations
@entry_kvs = {
'Layer' => 'resque',
'Label' => 'entry' }
@exit_kvs = { 'Layer' => 'resque', 'Label' => 'exit' }
end
it 'Stock Resque should be loaded, defined and ready' do
defined?(::Resque).wont_match nil
defined?(::Resque::Worker).wont_match nil
defined?(::Resque::Job).wont_match nil
end
it 'Resque should have oboe methods defined' do
[ :enqueue, :enqueue_to, :dequeue ].each do |m|
::Resque.method_defined?("#{m}_with_oboe").must_equal true
end
::Resque::Worker.method_defined?("perform_with_oboe").must_equal true
::Resque::Job.method_defined?("fail_with_oboe").must_equal true
end
it "should trace enqueue" do
skip
Oboe::API.start_trace('resque-client_test', '', {}) do
Resque.enqueue(OboeResqueJob, { :generate => :activerecord, :delay => rand(5..30).to_f })
Resque.enqueue(OboeResqueJobThatFails)
Resque.dequeue(OboeResqueJob, { :generate => :moped })
end
traces = get_all_traces
traces.count.must_equal 4
validate_outer_layers(traces, 'resque-client_test')
validate_event_keys(traces[1], @entry_kvs)
validate_event_keys(traces[2], @exit_kvs)
end
it "should trace dequeue" do
skip
Oboe::API.start_trace('resque-client_test', '', {}) do
Resque.dequeue(OboeResqueJob, { :generate => :moped })
end
traces = get_all_traces
traces.count.must_equal 4
validate_outer_layers(traces, 'resque-client_test')
validate_event_keys(traces[1], @entry_kvs)
validate_event_keys(traces[2], @exit_kvs)
end
end
Version data entries
49 entries across 49 versions & 1 rubygems