class Resources::Tube
Public Instance Methods
buried()
click to toggle source
# File lib/pvdgm-bs-client/resources/tube.rb, line 64 def buried tube = tube_name result = get("beanstalk/tubes/#{Base64.urlsafe_encode64(tube_name)}/buried") if result.has_key?('error') puts puts result['error'] else puts "\nJobs in the Buried state:" table = Terminal::Table.new headings: [ 'Id', 'Body' ] do | t | t << [ result.keys.first, result.values.first ] end puts table end puts end
delayed()
click to toggle source
# File lib/pvdgm-bs-client/resources/tube.rb, line 48 def delayed tube = tube_name result = get("beanstalk/tubes/#{Base64.urlsafe_encode64(tube_name)}/delayed") if result.has_key?('error') puts puts result['error'] else puts "\nJobs in the Delayed state:" table = Terminal::Table.new headings: [ 'Id', 'Body' ] do | t | t << [ result.keys.first, result.values.first ] end puts table end puts end
delete_all_jobs()
click to toggle source
# File lib/pvdgm-bs-client/resources/tube.rb, line 88 def delete_all_jobs tube = tube_name puts state = prompter.choose do | menu | menu.prompt = "Select the state of the jobs to be deleted: " menu.choice('ready', 'All jobs in the ready state') { 'ready' } menu.choice('buried', 'All jobs in the buried state') { 'buried' } end result = delete("beanstalk/tubes/#{Base64.urlsafe_encode64(tube_name)}/all_jobs?state=#{state}") puts "\nAll jobs deleted" puts result['eat_job'] puts end
delete_one_job()
click to toggle source
# File lib/pvdgm-bs-client/resources/tube.rb, line 80 def delete_one_job tube = tube_name result = delete("beanstalk/tubes/#{Base64.urlsafe_encode64(tube_name)}/one_job") puts "\nJob deleted" puts result['eat_job'] puts end
kick()
click to toggle source
# File lib/pvdgm-bs-client/resources/tube.rb, line 119 def kick tube = tube_name num_jobs = prompter.ask("Number of jobs to kick: ", Integer) { |q| q.default = 1 } result = get("beanstalk/tubes/#{Base64.urlsafe_encode64(tube_name)}/kick/#{num_jobs}") puts "\nKick #{num_jobs} in tube '#{tube}':" puts result['kick'] puts end
kill_worker()
click to toggle source
# File lib/pvdgm-bs-client/resources/tube.rb, line 111 def kill_worker tube = tube_name result = delete("beanstalk/tubes/#{Base64.urlsafe_encode64(tube_name)}/worker") puts "\nWorker killed:" puts result['kill_worker'] puts end
list()
click to toggle source
# File lib/pvdgm-bs-client/resources/tube.rb, line 7 def list result = get("beanstalk/tubes") puts "\nBeanstalk tubes" table = Terminal::Table.new headings: [ 'Tube Name' ] do | t | result.each do | tube_name | t << [ tube_name ] end end puts table puts end
move()
click to toggle source
# File lib/pvdgm-bs-client/resources/tube.rb, line 102 def move tube = tube_name to_tube = to_tube_name result = delete("beanstalk/tubes/#{Base64.urlsafe_encode64(tube_name)}/move/#{Base64.urlsafe_encode64(to_tube)}") puts "\nAll jobs moved from '#{tube}' to '#{to_tube}':" puts result['eat_job'] puts end
ready()
click to toggle source
# File lib/pvdgm-bs-client/resources/tube.rb, line 32 def ready tube = tube_name result = get("beanstalk/tubes/#{Base64.urlsafe_encode64(tube_name)}/ready") if result.has_key?('error') puts puts result['error'] else puts "\nJobs in the Ready state:" table = Terminal::Table.new headings: [ 'Id', 'Body' ] do | t | t << [ result.keys.first, result.values.first ] end puts table end puts end
show()
click to toggle source
# File lib/pvdgm-bs-client/resources/tube.rb, line 19 def show tube = tube_name result = get("beanstalk/tubes/#{Base64.urlsafe_encode64(tube_name)}") puts "\nStatistics for tube: #{tube}" table = Terminal::Table.new headings: [ 'Key', 'Value' ] do | t | result.each_pair do | key, value | t << [ key, value ] end end puts table puts end