puppetlabs/vmpooler-provider-gce
2
0
Fork 0
mirror of https://github.com/puppetlabs/vmpooler-provider-gce.git synced 2026-01-26 03:18:41 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

adding purge unconfigured method

Browse source
This commit is contained in:
Samuel Beaulieu 2021-12-07 13:08:21 -06:00
parent c85fed771f
commit 761c96fd38
No known key found for this signature in database
GPG key ID: 12030F74136D0F34
2 changed files with 39 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

40
lib/vmpooler/providers/gce.rb
View file

@ -444,18 +444,44 @@ module Vmpooler
filter[zone(pool)] = [] if filter[zone(pool)].nil?
filter[zone(pool)] << "(labels.pool != #{pool} OR -labels.pool:*)"
end
vm_to_purge = []
filter.keys.each do |zone|
#VMs
instance_list = connection.list_instances(project, zone, filter: filter[zone].join(" AND "))
next if instance_list.items.nil?
instance_list.items.each do |vm|
next if !vm.labels.nil? && whitelist&.include?(vm.labels['pool'])
next if whitelist&.include?("") && vm.labels.nil?
vm_to_purge << vm.name
result_list = []
unless instance_list.items.nil?
instance_list.items.each do |vm|
next if !vm.labels.nil? && whitelist&.include?(vm.labels['pool'])
next if whitelist&.include?("") && vm.labels.nil?
result = connection.delete_instance(project, zone, vm.name)
result_list << result
end
end
#now check they are done
result_list.each do |result|
wait_for_operation(project, pool_name, result, connection)
end
#Disks
disks_list = connection.list_disks(project, zone, filter: filter[zone].join(" AND "))
unless disks_list.items.nil?
disks_list.items.each do |disk|
next if !disk.labels.nil? && whitelist&.include?(disk.labels['pool'])
next if whitelist&.include?("") && disk.labels.nil?
result = connection.delete_disk(project, zone, disk.name)
end
end
#Snapshots
snapshot_list = connection.list_snapshots(project, filter: filter[zone].join(" AND "))
unless snapshot_list.items.nil?
snapshot_list.items.each do |sn|
next if !sn.labels.nil? && whitelist&.include?(sn.labels['pool'])
next if whitelist&.include?("") && sn.labels.nil?
result = connection.delete_snapshot(project, sn.name)
end
end
end
puts vm_to_purge
end
end