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