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