Class: RightScale::Request

Inherits:
Packet show all
Defined in:
lib/right_agent/packets.rb

Overview

Packet for a work request for an actor node that has an expected result

Constant Summary collapse

DEFAULT_OPTIONS = 
{:selector => :any}

Constants inherited from Packet

Packet::DEFAULT_VERSION, Packet::GLOBAL, Packet::NOT_SERIALIZED, Packet::PACKET_SIZE_REGEXP, Packet::VERSION

Instance Attribute Summary collapse

Attributes inherited from Packet

#received_at, #size

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Packet

compatible, #enough_precision, #id_to_s, #ids_to_s, json_create, msgpack_create, #name, #recv_version, #send_version, #send_version=, #to_json, #to_msgpack, #trace

Constructor Details

#initialize(type, payload, opts = {}, version = [VERSION, VERSION], size = nil) ⇒ Request

Create packet

Parameters

type(String)

Dispatch route for the request

payload(Any)

Arbitrary data that is transferred to actor

opts(Hash)

Optional settings:

:from(String)

Sender identity

:scope(Hash)

Define behavior that should be used to resolve tag based routing

:token(String)

Generated request id that a router uses to identify replies

:reply_to(String)

Identity of the node that actor replies to, usually a router itself

:selector(Symbol)

Selector used to route the request: :any or :all, defaults to :any,

  :all deprecated for version 13 and above
:target(String|Array):: Target recipient(s)
:persistent(Boolean):: Indicates if this request should be saved to persistent storage
  by the AMQP broker
:expires_at(Integer|nil):: Time in seconds in Unix-epoch when this request expires and
   is to be ignored by the receiver; value 0 means never expire; defaults to 0
:tags(Array(Symbol)):: List of tags to be used for selecting target for this request
:tries(Array):: List of tokens for previous attempts to send this request
version(Array)

Protocol version of the original creator of the packet followed by the

protocol version of the packet contents to be used when sending
size(Integer)

Size of request in bytes used only for marshalling



314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
 
# File 'lib/right_agent/packets.rb', line 314

def initialize(type, payload, opts = {}, version = [VERSION, VERSION], size = nil)
  opts = DEFAULT_OPTIONS.merge(opts)
  @type       = type
  @payload    = payload
  @from       = opts[:from]
  @scope      = opts[:scope]
  @token      = opts[:token]
  @reply_to   = opts[:reply_to]
  @selector   = opts[:selector]
  @selector   = :any if ["least_loaded", "random"].include?(@selector.to_s)
  @target     = opts[:target]
  @persistent = opts[:persistent]
  @expires_at = opts[:expires_at] || 0
  @tags       = opts[:tags] || []
  @tries      = opts[:tries] || []
  @version    = version
  @size       = size
end

Instance Attribute Details

#expires_at ⇒ Object

Returns the value of attribute expires_at.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def expires_at
  @expires_at
end

#from ⇒ Object

Returns the value of attribute from.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def from
  @from
end

#payload ⇒ Object

Returns the value of attribute payload.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def payload
  @payload
end

#persistent ⇒ Object

Returns the value of attribute persistent.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def persistent
  @persistent
end

#reply_to ⇒ Object

Returns the value of attribute reply_to.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def reply_to
  @reply_to
end

#scope ⇒ Object

Returns the value of attribute scope.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def scope
  @scope
end

#selector ⇒ Object

Returns the value of attribute selector.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def selector
  @selector
end

#tags ⇒ Object

Returns the value of attribute tags.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def tags
  @tags
end

#target ⇒ Object

Returns the value of attribute target.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def target
  @target
end

#token ⇒ Object

Returns the value of attribute token.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def token
  @token
end

#tries ⇒ Object

Returns the value of attribute tries.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def tries
  @tries
end

#type ⇒ Object

Returns the value of attribute type.



287
288
289
 
# File 'lib/right_agent/packets.rb', line 287

def type
  @type
end

Class Method Details

.create(o) ⇒ Object

Create packet from unmarshalled data

Parameters

o(Hash)

Unmarshalled data

Return

(Request)

New packet



348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
 
# File 'lib/right_agent/packets.rb', line 348

def self.create(o)
  i = o['data']
  expires_at = if i.has_key?('created_at')
    created_at = i['created_at'].to_i
    created_at > 0 ? created_at + (15 * 60) : 0
  else
    i['expires_at']
  end
  new(i['type'], i['payload'], { :from       => self.compatible(i['from']), :scope      => i['scope'],
                                 :token      => i['token'],                 :reply_to   => self.compatible(i['reply_to']),
                                 :selector   => i['selector'],              :target     => self.compatible(i['target']),
                                 :persistent => i['persistent'],            :tags       => i['tags'],
                                 :expires_at => expires_at,                 :tries      => i['tries'] },
      i['version'] || [DEFAULT_VERSION, DEFAULT_VERSION], o['size'])
end

Instance Method Details

#fanout? ⇒ Boolean

Test whether the request is being fanned out to multiple targets

Return

(Boolean)

true if is multicast, otherwise false

Returns:

  • (Boolean) 


337
338
339
 
# File 'lib/right_agent/packets.rb', line 337

def fanout?
  @selector.to_s == 'all'
end

#one_way ⇒ Object

Whether the packet is one that does not have an associated response

Return

false

Always return false



408
409
410
 
# File 'lib/right_agent/packets.rb', line 408

def one_way
  false
end

#target_for_encryption ⇒ Object

Get target to be used for encrypting the packet

Return

(String)

Target



400
401
402
 
# File 'lib/right_agent/packets.rb', line 400

def target_for_encryption
  @target
end

#to_s(filter = nil, version = nil) ⇒ Object

Generate log representation

Parameters

filter(Array(Symbol))

Attributes to be included in output

version(Symbol|nil)

Version to display: :recv_version, :send_version, or nil meaning none

Return

log_msg(String)

Log representation



372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
 
# File 'lib/right_agent/packets.rb', line 372

def to_s(filter = nil, version = nil)
  payload = PayloadFormatter.log(@type, @payload)
  log_msg = "#{super(filter, version)} #{trace} #{@type}"
  log_msg += " #{payload}" if payload
  log_msg += " from #{id_to_s(@from)}" if filter.nil? || filter.include?(:from)
  log_msg += ", target #{ids_to_s(@target)}" if @target && (filter.nil? || filter.include?(:target))
  log_msg += ", scope #{@scope.inspect}" if @scope && (filter.nil? || filter.include?(:scope))
  log_msg += ", fanout" if (filter.nil? || filter.include?(:fanout)) && fanout?
  log_msg += ", reply_to #{id_to_s(@reply_to)}" if @reply_to && (filter.nil? || filter.include?(:reply_to))
  log_msg += ", tags #{@tags.inspect}" if @tags && !@tags.empty? && (filter.nil? || filter.include?(:tags))
  log_msg += ", persistent" if @persistent && (filter.nil? || filter.include?(:persistent))
  log_msg += ", tries #{tries_to_s}" if @tries && !@tries.empty? && (filter.nil? || filter.include?(:tries))
  log_msg += ", payload #{@payload.inspect}" if filter && filter.include?(:payload)
  log_msg
end

#tries_to_s ⇒ Object

Convert tries list to string representation

Return

log_msg(String)

Tries list



392
393
394
 
# File 'lib/right_agent/packets.rb', line 392

def tries_to_s
  @tries.map { |t| "<#{t}>" }.join(", ")
end