Class: Workiq::Storage
- Inherits:
-
Object
- Object
- Workiq::Storage
- Defined in:
- lib/workiq/storage.rb
Class Method Summary collapse
Class Method Details
.read_field(jid, field) ⇒ Object
16 17 18 19 20 |
# File 'lib/workiq/storage.rb', line 16 def read_field(jid, field) Sidekiq.redis do |conn| conn.hmget(jid, field)[0] end end |
.store_field(jid, field) ⇒ Object
5 6 7 8 9 10 11 12 13 14 |
# File 'lib/workiq/storage.rb', line 5 def store_field(jid, field) Sidekiq.redis do |conn| result = conn.multi do conn.hmset jid, *(field.to_a.flatten) conn.expire jid, Workiq::DEFAULT_EXPIRY conn.publish "#{jid}-field-update", jid end result[0] end end |