Contents

module RedisFailover
  # Runner is responsible for bootstrapping the redis Node Manager.
  class Runner
    def self.run(options)
      options = CLI.parse(options)
      @node_manager = NodeManager.new(options)
      trap_signals
      node_manager_thread = Thread.new { @node_manager.start }
      Util.logger.info("Redis Node Manager successfully started.")
      node_manager_thread.join
    end

    def self.node_manager
      @node_manager
    end

    def self.trap_signals
      [:INT, :TERM].each do |signal|
        previous_signal = trap(signal) do
          Util.logger.info('Shutting down ...')
          if previous_signal && previous_signal.respond_to?(:call)
            previous_signal.call
          end
          @node_manager.shutdown
          exit(0)
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
redis_failover-0.5.2	lib/redis_failover/runner.rb
redis_failover-0.5.1	lib/redis_failover/runner.rb
redis_failover-0.5.0	lib/redis_failover/runner.rb