Class: StackMate::CloudStackNicToVirtualMachine
Constant Summary
Constants included
from Resolver
Resolver::INTEXP, Resolver::STRINGEXP, Resolver::UUIDEXP
Instance Attribute Summary
#name
Instance Method Summary
collapse
Methods included from Resolver
#get_named_tag, #get_resolved, #recursive_resolve, #resolve_tags, #resolve_to_deviceid, #validate_param
Methods included from Intrinsic
#fn_base64, #fn_getatt, #fn_join, #fn_lookup, #fn_map, #fn_ref, #fn_select, #intrinsic
Methods included from Logging
configure_logger_for, #logger, logger_for
#initialize, #set_metadata
Instance Method Details
#create ⇒ Object
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
# File 'lib/stackmate/participants/cloudstack_nictovirtualmachine.rb', line 9
def create
logger.debug("Creating resource #{@name}")
workitem[@name] = {}
name_cs = workitem['StackName'] + '-' + @name
args={}
begin
args['virtualmachineid'] = get_virtualmachineid
args['networkid'] = get_networkid
args['ipaddress'] = get_ipaddress if @props.has_key?('ipaddress')
logger.info("Creating resource #{@name} with following arguments")
p args
result_obj = make_async_request('addNicToVirtualMachine',args)
resource_obj = result_obj['NicToVirtualMachine'.downcase]
resource_obj.each_key do |k|
val = resource_obj[k]
if('id'.eql?(k))
k = 'physical_id'
end
workitem[@name][k] = val
end
set_tags(@props['tags'],workitem[@name]['physical_id'],"UserVM") if @props.has_key?('tags')
set_metadata if workitem['Resources'][@name].has_key?('Metadata')
workitem['ResolvedNames'][@name] = name_cs
workitem['IdMap'][workitem[@name]['physical_id']] = @name
rescue NoMethodError => nme
logger.error("Create request failed for resource . Cleaning up the stack")
raise nme
rescue Exception => e
logger.error(e.message)
raise e
end
end
|
#delete ⇒ Object
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
# File 'lib/stackmate/participants/cloudstack_nictovirtualmachine.rb', line 47
def delete
logger.debug("Deleting resource #{@name}")
begin
physical_id = workitem[@name]['physical_id'] if !workitem[@name].nil?
if(!physical_id.nil?)
args = {'virtualmachineid' => physical_id
}
result_obj = make_async_request('removeNicToVirtualMachine',args)
if (!(result_obj['error'] == true))
logger.info("Successfully deleted resource #{@name}")
else
workitem[@name]['delete_error'] = true
logger.info("CloudStack error while deleting resource #{@name}")
end
else
logger.info("Resource not created in CloudStack. Skipping delete...")
end
rescue Exception => e
logger.error("Unable to delete resorce #{@name}")
end
end
|
#get_ipaddress ⇒ Object
98
99
100
101
102
103
104
|
# File 'lib/stackmate/participants/cloudstack_nictovirtualmachine.rb', line 98
def get_ipaddress
resolved_ipaddress = get_resolved(@props['ipaddress'],workitem)
if resolved_ipaddress.nil? || !validate_param(resolved_ipaddress,"string")
raise "Malformed optional parameter ipaddress for resource #{@name}"
end
resolved_ipaddress
end
|
#get_networkid ⇒ Object
90
91
92
93
94
95
96
|
# File 'lib/stackmate/participants/cloudstack_nictovirtualmachine.rb', line 90
def get_networkid
resolved_networkid = get_resolved(@props["networkid"],workitem)
if resolved_networkid.nil? || !validate_param(resolved_networkid,"uuid")
raise "Missing mandatory parameter networkid for resource #{@name}"
end
resolved_networkid
end
|
#get_virtualmachineid ⇒ Object
82
83
84
85
86
87
88
|
# File 'lib/stackmate/participants/cloudstack_nictovirtualmachine.rb', line 82
def get_virtualmachineid
resolved_virtualmachineid = get_resolved(@props["virtualmachineid"],workitem)
if resolved_virtualmachineid.nil? || !validate_param(resolved_virtualmachineid,"uuid")
raise "Missing mandatory parameter virtualmachineid for resource #{@name}"
end
resolved_virtualmachineid
end
|
#on_workitem ⇒ Object
69
70
71
72
73
74
75
76
77
78
79
80
|
# File 'lib/stackmate/participants/cloudstack_nictovirtualmachine.rb', line 69
def on_workitem
@name = workitem.participant_name
@props = workitem['Resources'][@name]['Properties']
@props.downcase_key
@resolved_names = workitem['ResolvedNames']
if workitem['params']['operation'] == 'create'
create
else
delete
end
reply
end
|