Contents

require 'bundler/setup'
require 'active_support/core_ext/integer/time'
require 'celluloid'
require 'redis'
require 'connection_pool'
require 'json'

require 'maxwell/agent/configuration'
require 'maxwell/agent/dynamic_attributes'
require 'maxwell/agent/middleware/chain'
require 'maxwell/agent/middleware/logging'
require 'maxwell/agent/work'
require 'maxwell/agent/host'
require 'maxwell/agent/probe'


module Maxwell
  module Agent
    class << self
      def runner
        @runner
      end

      def configuration
        @configuration ||= Configuration.new
      end

      def configure
        yield configuration if block_given?
        configuration
      end

      def start
        if dead_runner?
          @runner = Runner.run
        end
      end

      def start!
        if dead_runner?
          @runner = Runner.run!
        end
      end

      def stop
        runner.terminate
      end

      def middleware
        yield configuration.middleware_chain if block_given?
        configuration.middleware_chain
      end

      def running?
        runner.alive?
      end

      def stopped?
        !running?
      end

      def redis(&block)
        @redis ||= ConnectionPool.new(
          size: (configuration.worker_concurrency + 2)) {
            Redis.new configuration.redis_options
          }
        @redis.with(&block)
      end

    private

      def dead_runner?
        if runner && runner.alive?
          false
        else
          true
        end
      end

      def cleanup_dead_runner
        if dead_runner?
          @runner = nil
        end
      end
    end
  end
end

Dir[File.dirname(__FILE__) + '/../plugins/*.rb'].each do |file|
  require file
end

require 'maxwell/agent/runner'

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
maxwell_agent-0.0.5	lib/maxwell/agent.rb