Class: Skynet::WorkerVersionMessage

Inherits:
Message
  • Object
show all
Defined in:
lib/skynet/skynet_message.rb

Overview

END class Message

Instance Attribute Summary

Attributes inherited from Message

#payload_type, #tasktype

Class Method Summary collapse

Instance Method Summary collapse

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