Developpement of enabled/disabled state

This commit is contained in:
Etienne CARRIERE 2015-11-18 06:52:03 +01:00
parent be9058201f
commit aaf16fe337

View file

@ -54,9 +54,13 @@ options:
choices: ['yes', 'no'] choices: ['yes', 'no']
state: state:
description: description:
- Pool member state - Virtual Server state
required: false required: false
default: present default: present
description:
- Absent : delete the VS if present
- present (and its synonym enabled) : create if needed the VS and set state to enabled
- absent : create if needed the VS and set state to disabled
choices: ['present', 'absent', 'enabled', 'disabled'] choices: ['present', 'absent', 'enabled', 'disabled']
aliases: [] aliases: []
partition: partition:
@ -292,7 +296,22 @@ def set_port(api,name,port):
except bigsuds.OperationFailed, e: except bigsuds.OperationFailed, e:
raise Exception('Error on setting port : %s'% e ) raise Exception('Error on setting port : %s'% e )
def get_state(api,name):
return api.LocalLB.VirtualServer.get_enabled_state(virtual_servers = [name])[0]
def set_state(api,name,state):
updated=False
try:
current_state=get_state(api,name)
# We consider that being present is equivalent to enabled
if state == 'present':
state='enabled'
if STATES[state] != current_state:
api.LocalLB.VirtualServer.set_enabled_state(virtual_servers=[name],states=[STATES[state]])
updated=True
return updated
except bigsuds.OperationFailed, e:
raise Exception('Error on setting state : %s'% e )
def get_description(api,name): def get_description(api,name):
return api.LocalLB.VirtualServer.get_description(virtual_servers = [name])[0] return api.LocalLB.VirtualServer.get_description(virtual_servers = [name])[0]
@ -386,7 +405,7 @@ def main():
# check-mode return value # check-mode return value
result = {'changed': True} result = {'changed': True}
elif state == 'present': else:
update = False update = False
if not vs_exists(api, name): if not vs_exists(api, name):
if (not destination) or (not port): if (not destination) or (not port):
@ -403,6 +422,7 @@ def main():
set_snat(api,name,snat) set_snat(api,name,snat)
set_description(api,name,description) set_description(api,name,description)
set_default_persistence_profiles(api,name,default_persistence_profile) set_default_persistence_profiles(api,name,default_persistence_profile)
set_state(api,name,state)
result = {'changed': True} result = {'changed': True}
except bigsuds.OperationFailed, e: except bigsuds.OperationFailed, e:
raise Exception('Error on creating Virtual Server : %s' % e) raise Exception('Error on creating Virtual Server : %s' % e)
@ -424,6 +444,7 @@ def main():
result['changed']|=set_snat(api,name,snat) result['changed']|=set_snat(api,name,snat)
result['changed']|=set_profiles(api,name,all_profiles) result['changed']|=set_profiles(api,name,all_profiles)
result['changed']|=set_default_persistence_profiles(api,name,default_persistence_profile) result['changed']|=set_default_persistence_profiles(api,name,default_persistence_profile)
result['changed']|=set_state(api,name,state)
api.System.Session.submit_transaction() api.System.Session.submit_transaction()
except Exception,e: except Exception,e:
raise Exception("Error on updating Virtual Server : %s" % e) raise Exception("Error on updating Virtual Server : %s" % e)
@ -431,16 +452,6 @@ def main():
# check-mode return value # check-mode return value
result = {'changed': True} result = {'changed': True}
elif state in ('disabled', 'enabled'):
if name is None:
module.fail_json(msg="name parameter required when " \
"state=enabled/disabled")
if not module.check_mode:
pass
else:
# check-mode return value
result = {'changed': True}
except Exception, e: except Exception, e:
module.fail_json(msg="received exception: %s" % e) module.fail_json(msg="received exception: %s" % e)