Class: Bolt::Inventory::Inventory
- Inherits:
-
Object
- Object
- Bolt::Inventory::Inventory
- Defined in:
- lib/bolt/inventory/inventory.rb
Defined Under Namespace
Classes: WildcardError
Constant Summary collapse
- EXTENDED_TARGET_REGEX =
Getting targets from the inventory using ‘–targets’ supports extended glob pattern matching. In this case, use the extended regex so Bolt only uses commas outside brackets and braces as delimiters.
/[[:space:],]+(?=[^\]}]*(?:[\[{]|$))/.freeze
- TARGET_REGEX =
/[[:space:],]+/.freeze
Instance Attribute Summary collapse
-
#plugins ⇒ Object
readonly
Returns the value of attribute plugins.
-
#source ⇒ Object
readonly
Returns the value of attribute source.
-
#targets ⇒ Object
readonly
Returns the value of attribute targets.
-
#transport ⇒ Object
readonly
Returns the value of attribute transport.
Instance Method Summary collapse
- #add_facts(target, new_facts = {}) ⇒ Object
- #add_to_group(targets, desired_group) ⇒ Object
- #clear_alia_from_group(group, target_name) ⇒ Object
-
#config ⇒ Hash[String, Bolt::Config::Transport]
Return a map of transport configuration for the inventory.
-
#create_target_from_hash(data) ⇒ Object
Add a brand new target, overriding any existing target with the same name.
-
#create_target_from_inventory(target_name) ⇒ Object
Pull in a target definition from the inventory file and evaluate any associated references.
- #facts(target) ⇒ Object
- #features(target) ⇒ Object
- #get_target(target) ⇒ Object
- #get_targets(targets, ext_glob: false) ⇒ Object
-
#group_data_for(target_name) ⇒ Object
PRIVATE ####.
-
#group_lookup ⇒ Hash[String, Bolt::Inventory::Group]
Return a map of all groups in the inventory.
-
#group_names ⇒ Array[String]
Return a list of all group names in the inventory.
- #group_names_for(target_name) ⇒ Object
-
#groups ⇒ Bolt::Inventory::Group
Load and resolve the groups in the inventory.
-
#initialize(data, transport, transports, plugins, source = nil) ⇒ Inventory
constructor
A new instance of Inventory.
-
#match_wildcard?(wildcard, target_name, ext_glob: false) ⇒ Boolean
Does a target match the glob-style wildcard? Ignore case; use extended globs (a,b) when running from the CLI.
- #plugin_hooks(target) ⇒ Object
- #remove_from_group(target, desired_group) ⇒ Object
- #resource(target, type, title) ⇒ Object
- #resources(target) ⇒ Object
- #set_config(target, key_or_key_path, value) ⇒ Object
- #set_feature(target, feature, value = true) ⇒ Object
- #set_var(target, var_hash) ⇒ Object
- #target_config(target) ⇒ Object
- #target_implementation_class ⇒ Object
- #target_names ⇒ Object (also: #node_names)
- #transport_data_get ⇒ Object
- #validate_target_from_hash(target) ⇒ Object
- #vars(target) ⇒ Object
- #version ⇒ Object
Constructor Details
#initialize(data, transport, transports, plugins, source = nil) ⇒ Inventory
Returns a new instance of Inventory.
23 24 25 26 27 28 29 30 31 32 |
# File 'lib/bolt/inventory/inventory.rb', line 23 def initialize(data, transport, transports, plugins, source = nil) @logger = Bolt::Logger.logger(self) @data = data || {} @transport = transport @config = transports @config_resolved = transports.values.all?(&:resolved?) @plugins = plugins @targets = {} @source = source end |
Instance Attribute Details
#plugins ⇒ Object (readonly)
Returns the value of attribute plugins.
9 10 11 |
# File 'lib/bolt/inventory/inventory.rb', line 9 def plugins @plugins end |
#source ⇒ Object (readonly)
Returns the value of attribute source.
9 10 11 |
# File 'lib/bolt/inventory/inventory.rb', line 9 def source @source end |
#targets ⇒ Object (readonly)
Returns the value of attribute targets.
9 10 11 |
# File 'lib/bolt/inventory/inventory.rb', line 9 def targets @targets end |
#transport ⇒ Object (readonly)
Returns the value of attribute transport.
9 10 11 |
# File 'lib/bolt/inventory/inventory.rb', line 9 def transport @transport end |
Instance Method Details
#add_facts(target, new_facts = {}) ⇒ Object
333 334 335 336 |
# File 'lib/bolt/inventory/inventory.rb', line 333 def add_facts(target, new_facts = {}) @targets[target.name].add_facts(new_facts) target end |
#add_to_group(targets, desired_group) ⇒ Object
310 311 312 313 314 315 316 317 318 319 |
# File 'lib/bolt/inventory/inventory.rb', line 310 def add_to_group(targets, desired_group) if group_names.include?(desired_group) targets.each do |target| # Add the inventory copy of the target add_target(groups, @targets[target.name], desired_group) end else raise ValidationError.new("Group #{desired_group} does not exist in inventory", nil) end end |
#clear_alia_from_group(group, target_name) ⇒ Object
285 286 287 288 289 290 291 292 |
# File 'lib/bolt/inventory/inventory.rb', line 285 def clear_alia_from_group(group, target_name) if group.all_target_names.include?(target_name) group.clear_alia(target_name) end group.groups.each do |grp| clear_alia_from_group(grp, target_name) end end |
#config ⇒ Hash[String, Bolt::Config::Transport]
Return a map of transport configuration for the inventory. Any unresolved plugin references are resolved.
75 76 77 78 79 80 81 82 |
# File 'lib/bolt/inventory/inventory.rb', line 75 def config if @config_resolved @config else @config_resolved = true @config.each_value { |t| t.resolve(@plugins) unless t.resolved? } end end |
#create_target_from_hash(data) ⇒ Object
Add a brand new target, overriding any existing target with the same name. This method does not honor target config from the inventory. This is used when Target.new is called from a plan or with a data hash.
232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 |
# File 'lib/bolt/inventory/inventory.rb', line 232 def create_target_from_hash(data) # If target already exists, delete old and replace with new, otherwise add to new to all group new_target = Bolt::Inventory::Target.new(data, self) existing_target = @targets.key?(new_target.name) validate_target_from_hash(new_target) @targets[new_target.name] = new_target if existing_target clear_alia_from_group(groups, new_target.name) else add_to_group([new_target], 'all') end if new_target.target_alias groups.insert_alia(new_target.name, Array(new_target.target_alias)) end new_target end |
#create_target_from_inventory(target_name) ⇒ Object
Pull in a target definition from the inventory file and evaluate any associated references. This is used when a target is resolved by get_targets.
218 219 220 221 222 223 224 225 226 227 |
# File 'lib/bolt/inventory/inventory.rb', line 218 def create_target_from_inventory(target_name) target_data = groups.target_collect(target_name) || { 'uri' => target_name } target = Bolt::Inventory::Target.new(target_data, self) @targets[target.name] = target add_to_group([target], 'all') target end |
#facts(target) ⇒ Object
338 339 340 |
# File 'lib/bolt/inventory/inventory.rb', line 338 def facts(target) @targets[target.name].facts end |
#features(target) ⇒ Object
346 347 348 |
# File 'lib/bolt/inventory/inventory.rb', line 346 def features(target) @targets[target.name].features end |
#get_target(target) ⇒ Object
103 104 105 106 107 108 109 |
# File 'lib/bolt/inventory/inventory.rb', line 103 def get_target(target) target_array = get_targets(target) if target_array.count > 1 raise ValidationError.new("'#{target}' refers to #{target_array.count} targets", nil) end target_array.first end |
#get_targets(targets, ext_glob: false) ⇒ Object
94 95 96 97 98 99 100 101 |
# File 'lib/bolt/inventory/inventory.rb', line 94 def get_targets(targets, ext_glob: false) target_array = (targets, ext_glob: ext_glob) if target_array.is_a? Array target_array.flatten.uniq(&:name) else [target_array] end end |
#group_data_for(target_name) ⇒ Object
PRIVATE ####
112 113 114 |
# File 'lib/bolt/inventory/inventory.rb', line 112 def group_data_for(target_name) groups.group_collect(target_name) end |
#group_lookup ⇒ Hash[String, Bolt::Inventory::Group]
Return a map of all groups in the inventory.
66 67 68 |
# File 'lib/bolt/inventory/inventory.rb', line 66 def group_lookup @group_lookup ||= groups.collect_groups end |
#group_names ⇒ Array[String]
Return a list of all group names in the inventory.
58 59 60 |
# File 'lib/bolt/inventory/inventory.rb', line 58 def group_names group_lookup.keys end |
#group_names_for(target_name) ⇒ Object
84 85 86 |
# File 'lib/bolt/inventory/inventory.rb', line 84 def group_names_for(target_name) group_data_for(target_name).fetch('groups', []) end |
#groups ⇒ Bolt::Inventory::Group
Load and resolve the groups in the inventory. Loading groups resolves all plugin references except for those for target data and config.
47 48 49 50 51 52 |
# File 'lib/bolt/inventory/inventory.rb', line 47 def groups @groups ||= Group.new(@data, @plugins, all_group: true).tap do |groups| groups.resolve_string_targets(groups.target_aliases, groups.all_targets) groups.validate end end |
#match_wildcard?(wildcard, target_name, ext_glob: false) ⇒ Boolean
Does a target match the glob-style wildcard? Ignore case; use extended globs (a,b) when running from the CLI.
118 119 120 121 122 123 124 125 |
# File 'lib/bolt/inventory/inventory.rb', line 118 def match_wildcard?(wildcard, target_name, ext_glob: false) if ext_glob File.fnmatch(wildcard, target_name, File::FNM_CASEFOLD | File::FNM_EXTGLOB) else regexp = Regexp.new("^#{Regexp.escape(wildcard).gsub('\*', '.*?')}$", Regexp::IGNORECASE) target_name =~ regexp end end |
#plugin_hooks(target) ⇒ Object
350 351 352 |
# File 'lib/bolt/inventory/inventory.rb', line 350 def plugin_hooks(target) @targets[target.name].plugin_hooks end |
#remove_from_group(target, desired_group) ⇒ Object
294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 |
# File 'lib/bolt/inventory/inventory.rb', line 294 def remove_from_group(target, desired_group) unless target.length == 1 raise ValidationError.new("'remove_from_group' expects a single Target, got #{target.length}", nil) end if desired_group == 'all' raise ValidationError.new("Cannot remove Target from Group 'all'", nil) end if group_names.include?(desired_group) remove_target(groups, @targets[target.first.name], desired_group) else raise ValidationError.new("Group #{desired_group} does not exist in inventory", nil) end end |
#resource(target, type, title) ⇒ Object
366 367 368 |
# File 'lib/bolt/inventory/inventory.rb', line 366 def resource(target, type, title) @targets[target.name].resource(type, title) end |
#resources(target) ⇒ Object
362 363 364 |
# File 'lib/bolt/inventory/inventory.rb', line 362 def resources(target) @targets[target.name].resources end |
#set_config(target, key_or_key_path, value) ⇒ Object
354 355 356 |
# File 'lib/bolt/inventory/inventory.rb', line 354 def set_config(target, key_or_key_path, value) @targets[target.name].set_config(key_or_key_path, value) end |
#set_feature(target, feature, value = true) ⇒ Object
342 343 344 |
# File 'lib/bolt/inventory/inventory.rb', line 342 def set_feature(target, feature, value = true) @targets[target.name].set_feature(feature, value) end |
#set_var(target, var_hash) ⇒ Object
325 326 327 |
# File 'lib/bolt/inventory/inventory.rb', line 325 def set_var(target, var_hash) @targets[target.name].set_var(var_hash) end |
#target_config(target) ⇒ Object
358 359 360 |
# File 'lib/bolt/inventory/inventory.rb', line 358 def target_config(target) @targets[target.name].config end |
#target_implementation_class ⇒ Object
38 39 40 |
# File 'lib/bolt/inventory/inventory.rb', line 38 def target_implementation_class Bolt::Target end |
#target_names ⇒ Object Also known as: node_names
88 89 90 |
# File 'lib/bolt/inventory/inventory.rb', line 88 def target_names groups.all_targets end |
#transport_data_get ⇒ Object
321 322 323 |
# File 'lib/bolt/inventory/inventory.rb', line 321 def transport_data_get { transport: transport, transports: config.transform_values(&:to_h) } end |
#validate_target_from_hash(target) ⇒ Object
253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 |
# File 'lib/bolt/inventory/inventory.rb', line 253 def validate_target_from_hash(target) used_groups = Set.new(group_names) used_targets = target_names # Make sure there are no group name conflicts if used_groups.include?(target.name) raise ValidationError.new("Target name #{target.name} conflicts with group of the same name", nil) end # Validate any aliases if (aliases = target.target_alias) unless aliases.is_a?(Array) || aliases.is_a?(String) msg = "Alias entry on #{t_name} must be a String or Array, not #{aliases.class}" raise ValidationError.new(msg, @name) end end # Make sure there are no conflicts with the new target aliases used_aliases = groups.target_aliases Array(target.target_alias).each do |alia| if used_groups.include?(alia) raise ValidationError.new("Alias #{alia} conflicts with group of the same name", nil) elsif used_targets.include?(alia) raise ValidationError.new("Alias #{alia} conflicts with target of the same name", nil) elsif used_aliases[alia] && used_aliases[alia] != target.name raise ValidationError.new( "Alias #{alia} refers to multiple targets: #{used_aliases[alia]} and #{target.name}", nil ) end end end |
#vars(target) ⇒ Object
329 330 331 |
# File 'lib/bolt/inventory/inventory.rb', line 329 def vars(target) @targets[target.name].vars end |
#version ⇒ Object
34 35 36 |
# File 'lib/bolt/inventory/inventory.rb', line 34 def version 2 end |