Sha256: 6360dea55ffb00f3efd19cbee900d28946264dcc9a0867526799b314f837948f
Contents?: true
Size: 676 Bytes
Versions: 8
Compression:
Stored size: 676 Bytes
Contents
require 'cellect/node_set'
require 'socket'
module Cellect
module Server
class NodeSet < Cellect::NodeSet
attr_accessor :id
protected
# Registers this server instance with ZooKeeper
def setup
zk.mkdir_p '/nodes'
# Find the local ipv4 address
address = Socket.ip_address_list.find{ |address| address.ipv4? && !address.ipv4_loopback? }
raise "Cannot identify IP address" unless address
# Register this instance with an autoincrementing id
path = zk.create '/nodes/node', data: address.ip_address, mode: :ephemeral_sequential
self.id = path.sub /^\/nodes\//, ''
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems