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

Fix rubocops

Browse source
This commit is contained in:
Jake Spain 2023-02-22 08:19:13 -05:00
parent fcf79c9421
commit 38064771aa
No known key found for this signature in database
GPG key ID: BC1C4DA0A085E113
1 changed files with 5 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -84,7 +84,7 @@ module Vmpooler
def domain(pool_name) def domain(pool_name)
dns_plugin_name = pool_config(pool_name)['dns_plugin'] dns_plugin_name = pool_config(pool_name)['dns_plugin']
return dns_config(dns_plugin_name) dns_config(dns_plugin_name)
end end
# Base methods that are implemented: # Base methods that are implemented:
@ -205,13 +205,12 @@ module Vmpooler
debug_logger('trigger insert_instance') debug_logger('trigger insert_instance')
result = connection.insert_instance(project, zone(pool_name), client) result = connection.insert_instance(project, zone(pool_name), client)
wait_for_operation(project, pool_name, result) wait_for_operation(project, pool_name, result)
created_instance = get_vm(pool_name, new_vmname) get_vm(pool_name, new_vmname)
created_instance
end end
def get_vm_ip_address(vm_name, pool_name) def get_vm_ip_address(vm_name, pool_name)
vm_object = get_vm(pool_name, vm_name) vm_object = get_vm(pool_name, vm_name)
return vm_object['ip'] vm_object['ip']
end end
# create_disk creates an additional disk for an existing VM. It will name the new # create_disk creates an additional disk for an existing VM. It will name the new
@ -425,7 +424,6 @@ module Vmpooler
unless deleted unless deleted
debug_logger("trigger delete_instance #{vm_name}") debug_logger("trigger delete_instance #{vm_name}")
vm_hash = get_vm(pool_name, vm_name)
result = connection.delete_instance(project, zone(pool_name), vm_name) result = connection.delete_instance(project, zone(pool_name), vm_name)
wait_for_operation(project, pool_name, result, 10) wait_for_operation(project, pool_name, result, 10)
end end
@ -462,10 +460,10 @@ module Vmpooler
true true
end end
def vm_ready?(_pool_name, vm_name) def vm_ready?(pool_name, vm_name)
begin begin
# TODO: we could use a healthcheck resource attached to instance # TODO: we could use a healthcheck resource attached to instance
domain = domain(_pool_name) domain = domain(pool_name)
open_socket(vm_name, domain) open_socket(vm_name, domain)
rescue StandardError => _e rescue StandardError => _e
return false return false
@ -498,8 +496,6 @@ module Vmpooler
debug_logger("trigger async delete_instance #{vm.name}") debug_logger("trigger async delete_instance #{vm.name}")
result = connection.delete_instance(project, zone, vm.name) result = connection.delete_instance(project, zone, vm.name)
vm_pool = vm.labels&.key?('pool') ? vm.labels['pool'] : nil
existing_vm = generate_vm_hash(vm, vm_pool)
result_list << result result_list << result
end end
# now check they are done # now check they are done