class TingYun::Configuration::Manager
Public Class Methods
new()
click to toggle source
module Arel
module Visitors class Visitor def initialize @dispatch = get_dispatch_cache end def accept object visit object end private def self.dispatch_cache Hash.new do |hash, klass| hash[klass] = "visit_#{(klass.name || '').gsub('::', '_')}" end end def get_dispatch_cache self.class.dispatch_cache end def dispatch @dispatch end def visit object send dispatch[object.class], object rescue NoMethodError => e raise e if respond_to?(dispatch[object.class], true) superklass = object.class.ancestors.find { |klass| respond_to?(dispatch[klass], true) } raise(TypeError, "Cannot visit #{object.class}") unless superklass dispatch[object.class] = dispatch[superklass] retry end end end
end 实现缓存的一种方式
# File lib/ting_yun/configuration/manager.rb, line 58 def initialize reset_to_defaults end
Public Instance Methods
[](key)
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 62 def [](key) @cache[key] end
add_config_for_testing(source, level=0)
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 122 def add_config_for_testing(source, level=0) raise 'Invalid config type for testing' unless [Hash, DottedHash].include?(source.class) @configs_for_testing << [source.freeze, level] reset_cache log_config(:add, source) end
app_names()
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 74 def app_names if TingYun::Agent.config[:'nbs.auto_app_naming'] begin [::TingYun::Frameworks.framework.root.split('/').last] rescue ::TingYun::Configuration.get_name end else ::TingYun::Configuration.get_name end end
config_classes_for_testing()
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 221 def config_classes_for_testing config_stack.map(&:class) end
evaluate_procs(value)
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 114 def evaluate_procs(value) if value.respond_to?(:call) instance_eval(&value) else value end end
fetch(key)
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 102 def fetch(key) config_stack.each do |config| next unless config accessor = key.to_sym if config.has_key?(accessor) return evaluate_procs(config[accessor]) #if it's proc end end nil end
finished_configuring?()
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 182 def finished_configuring? !@server_source.nil? end
flattened()
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 205 def flattened config_stack.reverse.inject({}) do |flat, layer| thawed_layer = layer.to_hash.dup thawed_layer.each do |k, v| begin thawed_layer[k] = instance_eval(&v) if v.respond_to?(:call) rescue => e ::TingYun::Agent.logger.debug("#{e.class.name} : #{e.message} - when accessing config key #{k}") thawed_layer[k] = nil end thawed_layer.delete(:config) end flat.merge(thawed_layer.to_hash) end end
has_key?(key)
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 66 def has_key?(key) @cache.has_key?(key) end
keys()
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 70 def keys @cache.keys end
log_config(direction, source)
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 195 def log_config(direction, source) # Just generating this log message (specifically calling # flattened.inspect) is expensive enough that we don't want to do it # unless we're actually going to be logging the message based on our # current log level. ::TingYun::Agent.logger.debug do "Updating config (#{direction}) from #{source.class}. Results: #{flattened.inspect}" end end
remove_config(source)
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 141 def remove_config(source) case source when YamlSource then @yaml_source = nil when DefaultSource then @default_source = nil when EnvironmentSource then @environment_source = nil when ManualSource then @manual_source = nil when ServerSource then @server_source = nil else @configs_for_testing.delete_if { |src, lvl| src == source } end reset_cache #invoke_callbacks(:remove,source) log_config(:remove, source) end
remove_config_type(sym)
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 129 def remove_config_type(sym) source = case sym when :environment then @environment_source when :server then @server_source when :manual then @manual_source when :yaml then @yaml_source when :default then @default_source end remove_config(source) end
replace_or_add_config(source)
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 160 def replace_or_add_config(source) source.freeze was_finished = finished_configuring? case source when YamlSource then @yaml_source = source when DefaultSource then @default_source = source when EnvironmentSource then @environment_source = source when ServerSource then @server_source = source when ManualSource then @manual_source = source else TingYun::Agent.logger.warn("Invalid config format; config will be ignored: #{source}") end reset_cache log_config(:add, source) TingYun::Agent.instance.events.notify(:finished_configuring) if !was_finished && finished_configuring? end
reset_cache()
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 98 def reset_cache @cache = Hash.new { |hash, key| hash[key] = self.fetch(key) } end
reset_to_defaults()
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 86 def reset_to_defaults @default_source = DefaultSource.new @environment_source = EnvironmentSource.new @yaml_source = nil @server_source = nil @manual_source = nil # @callbacks = Hash.new {|hash,key| hash[key] =[]}#存放需要merge本地和服务端配置的info' @configs_for_testing = [] reset_cache end
source(key)
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 187 def source(key) config_stack.each do |config| if config.respond_to?(key.to_sym) || config.has_key?(key.to_sym) return config end end end
to_collector_hash()
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 228 def to_collector_hash DottedHash.new(flattened).to_hash.delete_if do |k, v| default = DEFAULTS[k] if default default[:exclude_from_reported_settings] else # In our tests, we add totally bogus configs, because testing. # In those cases, there will be no default. So we'll just let # them through. false end end end
Private Instance Methods
config_stack()
click to toggle source
# File lib/ting_yun/configuration/manager.rb, line 244 def config_stack stack = [@environment_source, @server_source, @manual_source, @yaml_source, @default_source] stack.compact! @configs_for_testing.each do |config, at_start| if at_start stack.insert(0, config) else stack.push(config) end end stack end