class RSwim::Integration::Serializer
Public Class Methods
new(directory)
click to toggle source
# File lib/rswim/integration/serializer.rb, line 6 def initialize(directory) @directory = directory end
Public Instance Methods
serialize(message)
click to toggle source
# File lib/rswim/integration/serializer.rb, line 10 def serialize(message) l1 = message.type.to_s.gsub(/_/, '-') l1 << " #{@directory.host(message.payload[:target_id])}" if message.type == :ping_req message.payload[:updates].to_a.each do |update| # host status incarnation_number l1 << "\n#{@directory.host(update.member_id)} #{update.status} #{update.incarnation_number}" end l1 end
Protected Instance Methods
logger()
click to toggle source
# File lib/rswim/integration/serializer.rb, line 22 def logger @_logger ||= begin RSwim::Logger.new(self.class, STDERR) end end