Sha256: 7008cd7a9e219ed0e38c20c7d95b7ab969eebc1c4ab2bf3b6a2c8deaf2b58fcd
Contents?: true
Size: 1.42 KB
Versions: 13
Compression:
Stored size: 1.42 KB
Contents
module Skylight
module Worker
class Builder
include Util::Logging
attr_reader :config
def initialize(config = Config.new)
if Hash === config
config = Config.new(config)
end
@config = config
end
def build
s = strategy.to_s
case s
when 'embedded'
trace "building embedded worker"
Collector.new(config)
when 'standalone'
trace "building standalone worker"
unless config[:'agent.sockfile_path']
raise ArgumentError, 'agent.sockfile_path config required'
end
Standalone.new(
config,
lockfile,
server)
else
raise "unknown strategy: `#{s}`"
end
end
private
def strategy
config.get(:'agent.strategy') || default_strategy
end
def default_strategy
ret = if jruby?
'embedded'
else
'standalone'
end
ret.downcase.strip
end
def lockfile
config.get(:'agent.lockfile') do
name = [ 'skylight', config.environment ].compact.join('-')
File.join(config[:'agent.sockfile_path'], "#{name}.pid")
end.to_s
end
def server
config.get(:'agent.server', Server)
end
def jruby?
defined?(RUBY_ENGINE) && RUBY_ENGINE == 'jruby'
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems