class Maxwell::Agent::Configuration

Attributes

host_configuration[RW]
middleware_chain[R]
redis_options[RW]
work_poll[RW]
worker_concurrency[RW]

Public Class Methods

new() click to toggle source
# File lib/maxwell/agent/configuration.rb, line 10
def initialize
  @worker_concurrency = 25
  @middleware_chain = default_middleware
  @work_poll = 1
  @host_configuration = 'config/host_configuration.json'
  @redis_options = { host: 'localhost', port: 6379 }
end

Public Instance Methods

default_middleware() click to toggle source
# File lib/maxwell/agent/configuration.rb, line 24
def default_middleware
  Middleware::Chain.new do |m|
    m.add Middleware::Logging
  end
end
middleware() { |middleware_chain| ... } click to toggle source
# File lib/maxwell/agent/configuration.rb, line 18
def middleware
  @middleware_chain ||= default_middleware
  yield @middleware_chain if block_given?
  @middleware_chain
end