Class: ReleaseTest
- Inherits:
-
BeanstalkIntegrationTest
- Object
- MiniTest::Should::TestCase
- BeanstalkIntegrationTest
- ReleaseTest
- Defined in:
- lib/beanstalk_integration_tests/release_test.rb
Instance Method Summary collapse
Methods inherited from BeanstalkIntegrationTest
address, #address, #build_client, #cleanup_tubes, #client, #create_buried_jobs, #generate_tube_name, #initialize, #tube_name, #uuid
Methods included from Timeout
Constructor Details
This class inherits a constructor from BeanstalkIntegrationTest
Instance Method Details
#assert_counter_delta(delta = 1, job_state = 'ready') ⇒ Object
176 177 178 179 180 181 182 183 184 185 186 187 188 189 |
# File 'lib/beanstalk_integration_tests/release_test.rb', line 176 def assert_counter_delta(delta = 1, job_state = 'ready') stats = client.transmit('stats')[:body] tube_stats = client.transmit("stats-tube #{tube_name}")[:body] assert_equal(@initial_cmd_release + delta, stats['cmd-release'], 'Expected cmd-release to be incremented') assert_equal(instance_variable_get("@initial_server_jobs_#{job_state}") + delta, stats["current-jobs-#{job_state}"], "Expected server current-jobs-#{job_state} to be incremented") assert_equal(instance_variable_get("@initial_tube_jobs_#{job_state}") + delta, tube_stats["current-jobs-#{job_state}"], "Expected tube current-jobs-#{job_state} to be incremented") if job_state == 'ready' assert_equal(@initial_server_jobs_urgent + delta, stats['current-jobs-urgent'], 'Expected server current-jobs-urgent to be incremented') assert_equal(@initial_tube_jobs_urgent + delta, tube_stats['current-jobs-urgent'], 'Expected tube current-jobs-urgent to be incremented') end assert_equal(@initial_job_releases + delta, client.transmit("stats-job #{@reserved_id}")[:body]['releases'], 'Expected job releases to be incremented') assert_equal(0, stats['current-jobs-reserved'], 'Expected server current-jobs-reserved to be zero') assert_equal(0, tube_stats['current-jobs-reserved'], 'Expected tube current-jobs-reserved to be zero') end |