class Raft4r::RaftServer
Public Class Methods
new(config, node_id)
click to toggle source
XXX handle cluster reconfig
# File lib/raft4r.rb, line 259 def initialize config, node_id s = config[node_id] raise 'Node not found' unless s @config = config @node_id = node_id @addr = s['bind'] @port = s['port'] LOGGER.info "Node: #{@node_id}, #{@addr}:#{@port}" end
Public Instance Methods
start_loop()
click to toggle source
# File lib/raft4r.rb, line 269 def start_loop LOGGER.info "Start RaftServer #{@addr}:#{@port}..." RPC::EMRPCServer.start_server @addr, @port, RaftHandler.new(@config, @node_id) end