| Class | +MCollective::Config | +
| In: | +
+
+ lib/mcollective/config.rb
+
+ + |
+
| Parent: | ++ Object + | +
+A pretty sucky config class, ripe for refactoring/improving +
+ +| classesfile | +[R] | ++ |
| collectives | +[R] | ++ |
| color | +[R] | ++ |
| configdir | +[R] | ++ |
| configfile | +[R] | ++ |
| configured | +[R] | ++ |
| connector | +[R] | ++ |
| daemonize | +[R] | ++ |
| daemonize | +[R] | ++ |
| default_discovery_method | +[R] | ++ |
| default_discovery_options | +[R] | ++ |
| direct_addressing | +[R] | ++ |
| direct_addressing_threshold | +[R] | ++ |
| fact_cache_time | +[R] | ++ |
| factsource | +[R] | ++ |
| identity | +[R] | ++ |
| keeplogs | +[R] | ++ |
| libdir | +[R] | ++ |
| logfacility | +[R] | ++ |
| logfile | +[R] | ++ |
| logger_type | +[R] | ++ |
| loglevel | +[R] | ++ |
| main_collective | +[R] | ++ |
| max_log_size | +[R] | ++ |
| mode | +[RW] | ++ |
| pluginconf | +[R] | ++ |
| publish_timeout | +[R] | ++ |
| registerinterval | +[R] | ++ |
| registration | +[R] | ++ |
| registration_collective | +[R] | ++ |
| rpcaudit | +[R] | ++ |
| rpcauditprovider | +[R] | ++ |
| rpcauthorization | +[R] | ++ |
| rpcauthprovider | +[R] | ++ |
| rpclimitmethod | +[R] | ++ |
| securityprovider | +[R] | ++ |
| ssl_cipher | +[R] | ++ |
| threaded | +[R] | ++ |
| ttl | +[R] | ++ |
+ # File lib/mcollective/config.rb, line 20 +20: def initialize +21: @configured = false +22: end ++
+ # File lib/mcollective/config.rb, line 24 + 24: def loadconfig(configfile) + 25: set_config_defaults(configfile) + 26: + 27: if File.exists?(configfile) + 28: File.readlines(configfile).each do |line| + 29: + 30: # strip blank spaces, tabs etc off the end of all lines + 31: line.gsub!(/\s*$/, "") + 32: + 33: unless line =~ /^#|^$/ + 34: if (line =~ /(.+?)\s*=\s*(.+)/) + 35: key = $1.strip + 36: val = $2 + 37: + 38: case key + 39: when "registration" + 40: @registration = val.capitalize + 41: when "registration_collective" + 42: @registration_collective = val + 43: when "registerinterval" + 44: @registerinterval = val.to_i + 45: when "collectives" + 46: @collectives = val.split(",").map {|c| c.strip} + 47: when "main_collective" + 48: @main_collective = val + 49: when "logfile" + 50: @logfile = val + 51: when "keeplogs" + 52: @keeplogs = val.to_i + 53: when "max_log_size" + 54: @max_log_size = val.to_i + 55: when "loglevel" + 56: @loglevel = val + 57: when "logfacility" + 58: @logfacility = val + 59: when "libdir" + 60: paths = val.split(File::PATH_SEPARATOR) + 61: paths.each do |path| + 62: raise("libdir paths should be absolute paths but '%s' is relative" % path) unless Util.absolute_path?(path) + 63: + 64: @libdir << path + 65: unless $LOAD_PATH.include?(path) + 66: $LOAD_PATH << path + 67: end + 68: end + 69: when "identity" + 70: @identity = val + 71: when "direct_addressing" + 72: @direct_addressing = Util.str_to_bool(val) + 73: when "direct_addressing_threshold" + 74: @direct_addressing_threshold = val.to_i + 75: when "color" + 76: @color = Util.str_to_bool(val) + 77: when "daemonize" + 78: @daemonize = Util.str_to_bool(val) + 79: when "securityprovider" + 80: @securityprovider = val.capitalize + 81: when "factsource" + 82: @factsource = val.capitalize + 83: when "connector" + 84: @connector = val.capitalize + 85: when "classesfile" + 86: @classesfile = val + 87: when /^plugin.(.+)$/ + 88: @pluginconf[$1] = val + 89: when "publish_timeout" + 90: @publish_timeout = val.to_i + 91: when "rpcaudit" + 92: @rpcaudit = Util.str_to_bool(val) + 93: when "rpcauditprovider" + 94: @rpcauditprovider = val.capitalize + 95: when "rpcauthorization" + 96: @rpcauthorization = Util.str_to_bool(val) + 97: when "rpcauthprovider" + 98: @rpcauthprovider = val.capitalize + 99: when "rpclimitmethod" +100: @rpclimitmethod = val.to_sym +101: when "logger_type" +102: @logger_type = val +103: when "fact_cache_time" +104: @fact_cache_time = val.to_i +105: when "ssl_cipher" +106: @ssl_cipher = val +107: when "threaded" +108: @threaded = Util.str_to_bool(val) +109: when "ttl" +110: @ttl = val.to_i +111: when "default_discovery_options" +112: @default_discovery_options << val +113: when "default_discovery_method" +114: @default_discovery_method = val +115: else +116: raise("Unknown config parameter '#{key}'") +117: end +118: end +119: end +120: end +121: +122: raise('The %s config file does not specify a libdir setting, cannot continue' % configfile) if @libdir.empty? +123: +124: I18n.load_path = Dir[File.expand_path(File.join(File.dirname(__FILE__), "locales", "*.yml"))] +125: I18n.locale = :en +126: +127: read_plugin_config_dir("#{@configdir}/plugin.d") +128: +129: raise 'Identities can only match /\w\.\-/' unless @identity.match(/^[\w\.\-]+$/) +130: +131: @configured = true +132: +133: @libdir.each {|dir| Log.warn("Cannot find libdir: #{dir}") unless File.directory?(dir)} +134: +135: if @logger_type == "syslog" +136: raise "The sylog logger is not usable on the Windows platform" if Util.windows? +137: end +138: +139: PluginManager.loadclass("Mcollective::Facts::#{@factsource}_facts") +140: PluginManager.loadclass("Mcollective::Connector::#{@connector}") +141: PluginManager.loadclass("Mcollective::Security::#{@securityprovider}") +142: PluginManager.loadclass("Mcollective::Registration::#{@registration}") +143: PluginManager.loadclass("Mcollective::Audit::#{@rpcauditprovider}") if @rpcaudit +144: PluginManager << {:type => "global_stats", :class => RunnerStats.new} +145: +146: Log.logmsg(:PLMC1, "The Marionette Collective version %{version} started by %{name} using config file %{config}", :info, :version => MCollective::VERSION, :name => $0, :config => configfile) +147: else +148: raise("Cannot find config file '#{configfile}'") +149: end +150: end ++
+ # File lib/mcollective/config.rb, line 192 +192: def read_plugin_config_dir(dir) +193: return unless File.directory?(dir) +194: +195: Dir.new(dir).each do |pluginconfigfile| +196: next unless pluginconfigfile =~ /^([\w]+).cfg$/ +197: +198: plugin = $1 +199: File.open("#{dir}/#{pluginconfigfile}", "r").each do |line| +200: # strip blank lines +201: line.gsub!(/\s*$/, "") +202: next if line =~ /^#|^$/ +203: if (line =~ /(.+?)\s*=\s*(.+)/) +204: key = $1.strip +205: val = $2 +206: @pluginconf["#{plugin}.#{key}"] = val +207: end +208: end +209: end +210: end ++
+ # File lib/mcollective/config.rb, line 152 +152: def set_config_defaults(configfile) +153: @stomp = Hash.new +154: @subscribe = Array.new +155: @pluginconf = Hash.new +156: @connector = "activemq" +157: @securityprovider = "Psk" +158: @factsource = "Yaml" +159: @identity = Socket.gethostname +160: @registration = "Agentlist" +161: @registerinterval = 0 +162: @registration_collective = nil +163: @classesfile = "/var/lib/puppet/state/classes.txt" +164: @rpcaudit = false +165: @rpcauditprovider = "" +166: @rpcauthorization = false +167: @rpcauthprovider = "" +168: @configdir = File.dirname(configfile) +169: @color = !Util.windows? +170: @configfile = configfile +171: @logger_type = "file" +172: @keeplogs = 5 +173: @max_log_size = 2097152 +174: @rpclimitmethod = :first +175: @libdir = Array.new +176: @fact_cache_time = 300 +177: @loglevel = "info" +178: @logfacility = "user" +179: @collectives = ["mcollective"] +180: @main_collective = @collectives.first +181: @ssl_cipher = "aes-256-cbc" +182: @direct_addressing = true +183: @direct_addressing_threshold = 10 +184: @default_discovery_method = "mc" +185: @default_discovery_options = [] +186: @ttl = 60 +187: @mode = :client +188: @publish_timeout = 2 +189: @threaded = false +190: end ++