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