Class: Fanforce::Worker::ErrorList
- Inherits:
-
Object
- Object
- Fanforce::Worker::ErrorList
- Defined in:
- lib/fanforce/worker/errors.rb
Constant Summary collapse
- Error =
Fanforce::Worker::Error
Instance Method Summary collapse
- #delete ⇒ Object
-
#initialize(queue_id, error_ids) ⇒ ErrorList
constructor
A new instance of ErrorList.
- #redis ⇒ Object
- #retry ⇒ Object
- #summaries ⇒ Object
Constructor Details
#initialize(queue_id, error_ids) ⇒ ErrorList
Returns a new instance of ErrorList.
158 159 160 161 |
# File 'lib/fanforce/worker/errors.rb', line 158 def initialize(queue_id, error_ids) @queue_id = queue_id @error_ids = error_ids end |
Instance Method Details
#delete ⇒ Object
191 192 193 194 195 196 197 198 |
# File 'lib/fanforce/worker/errors.rb', line 191 def delete redis.multi do @error_ids.each do |error_id| Error.delete(@queue_id, error_id) end end return nil end |
#redis ⇒ Object
163 |
# File 'lib/fanforce/worker/errors.rb', line 163 def redis; Fanforce::Worker::Errors.redis end |
#retry ⇒ Object
177 178 179 180 181 182 183 184 185 186 187 188 189 |
# File 'lib/fanforce/worker/errors.rb', line 177 def retry redis_responses = [] redis.multi do @error_ids.each do |error_id| redis_responses << Error.get_all(@queue_id, error_id) end end redis.multi do redis_responses.map do |redis_response| Error.retry(@queue_id, redis_response.value) end end end |
#summaries ⇒ Object
165 166 167 168 169 170 171 172 173 174 175 |
# File 'lib/fanforce/worker/errors.rb', line 165 def summaries redis_responses = [] redis.multi do @error_ids.each do |error_id| redis_responses << Error.get_summary(@queue_id, error_id) end end redis_responses.map do |redis_response| Error.format_summary(redis_response.value) end end |