Module: Resque::Helpers
- Included in:
- Resque, Job, Job, QueueStats, QueueStats, Stat, Worker, Worker
- Defined in:
- lib/resque/helpers.rb
Overview
Methods used by various classes in Resque.
Defined Under Namespace
Classes: DecodeException
Instance Method Summary collapse
-
#classify(dashed_word) ⇒ Object
Given a word with dashes, returns a camel cased version of it.
-
#constantize(camel_cased_word) ⇒ Object
Given a camel cased word, returns the constant it represents.
-
#decode(object) ⇒ Object
Given a string, returns a Ruby object.
-
#encode(object) ⇒ Object
Given a Ruby object, returns a string suitable for storage in a queue.
-
#mongo ⇒ Object
Direct access to the Redis instance.
- #mongo_queues ⇒ Object
- #mongo_stats ⇒ Object
- #mongo_workers ⇒ Object
Instance Method Details
#classify(dashed_word) ⇒ Object
Given a word with dashes, returns a camel cased version of it.
classify(‘job-name’) # => ‘JobName’
55 56 57 |
# File 'lib/resque/helpers.rb', line 55 def classify(dashed_word) dashed_word.split('-').each { |part| part[0] = part[0].chr.upcase }.join end |
#constantize(camel_cased_word) ⇒ Object
Given a camel cased word, returns the constant it represents
constantize(‘JobName’) # => JobName
62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 |
# File 'lib/resque/helpers.rb', line 62 def constantize(camel_cased_word) camel_cased_word = camel_cased_word.to_s if camel_cased_word.include?('-') camel_cased_word = classify(camel_cased_word) end names = camel_cased_word.split('::') names.shift if names.empty? || names.first.empty? constant = Object names.each do |name| constant = constant.const_get(name) || constant.const_missing(name) end constant end |
#decode(object) ⇒ Object
Given a string, returns a Ruby object.
34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 |
# File 'lib/resque/helpers.rb', line 34 def decode(object) return unless object if defined? Yajl begin Yajl::Parser.parse(object, :check_utf8 => false) rescue Yajl::ParseError => e raise DecodeException, e end else begin JSON.parse(object) rescue JSON::ParserError => e raise DecodeException, e end end end |
#encode(object) ⇒ Object
Given a Ruby object, returns a string suitable for storage in a queue.
25 26 27 28 29 30 31 |
# File 'lib/resque/helpers.rb', line 25 def encode(object) if defined? Yajl Yajl::Encoder.encode(object) else object.to_json end end |
#mongo ⇒ Object
Direct access to the Redis instance.
7 8 9 |
# File 'lib/resque/helpers.rb', line 7 def mongo Resque.mongo end |
#mongo_queues ⇒ Object
19 20 21 |
# File 'lib/resque/helpers.rb', line 19 def mongo_queues Resque.mongo_queues end |
#mongo_stats ⇒ Object
15 16 17 |
# File 'lib/resque/helpers.rb', line 15 def mongo_stats Resque.mongo_stats end |
#mongo_workers ⇒ Object
11 12 13 |
# File 'lib/resque/helpers.rb', line 11 def mongo_workers Resque.mongo_workers end |