Class: Skynet::WorkerVersionMessage
- Defined in:
- lib/skynet/skynet_message.rb
Overview
END class Message
Instance Attribute Summary
Attributes inherited from Message
Class Method Summary collapse
Instance Method Summary collapse
-
#initialize(opts) ⇒ WorkerVersionMessage
constructor
A new instance of WorkerVersionMessage.
- #template ⇒ Object
- #version ⇒ Object
Methods inherited from Message
#[], error_message, #error_message, error_template, #error_template, #fallback_task_message, fallback_task_message, #fallback_template, fallback_template, #fields, new_task_message, next_task_template, outstanding_results_template, outstanding_tasks_template, #payload, #payload=, #raw_payload, #raw_payload=, result_message, #result_message, result_template, #task, #timeout, #to_a, #to_h, #to_hash, #to_s
Methods included from SkynetDebugger
#args_pp, #debug, #debug_header, #error, #fatal, included, #info, #log, #printlog, #stderr, #stdout, #warn
Constructor Details
#initialize(opts) ⇒ WorkerVersionMessage
Returns a new instance of WorkerVersionMessage.
282 283 284 285 286 |
# File 'lib/skynet/skynet_message.rb', line 282 def initialize(opts) super self.expire_time ||= Time.now.to_i self.tasktype = :current_worker_rev end |
Class Method Details
.template ⇒ Object
292 293 294 295 296 297 298 299 |
# File 'lib/skynet/skynet_message.rb', line 292 def self.template template = { :tasktype => :current_worker_rev } fields.collect do |field| template[field] end end |
Instance Method Details
#template ⇒ Object
301 302 303 304 305 306 307 308 309 |
# File 'lib/skynet/skynet_message.rb', line 301 def template template = { :tasktype => :current_worker_rev, :expire_time => nil } fields.collect do |field| template[field] || self.send(field) end end |
#version ⇒ Object
288 289 290 |
# File 'lib/skynet/skynet_message.rb', line 288 def version @version.to_i end |