This commit is contained in:
Chris Archibald 2019-04-10 12:39:04 -07:00 committed by John R Barker
parent c582e89f45
commit 6661f17ce3

View file

@ -1,7 +1,6 @@
#!/usr/bin/python #!/usr/bin/python
# -*- coding: utf-8 -*-
# Copyright: (c) 2019, NetApp, Inc # (c) 2019, NetApp, Inc
# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt) # GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
from __future__ import absolute_import, division, print_function from __future__ import absolute_import, division, print_function
__metaclass__ = type __metaclass__ = type
@ -11,65 +10,64 @@ ANSIBLE_METADATA = {'metadata_version': '1.1',
'supported_by': 'certified'} 'supported_by': 'certified'}
DOCUMENTATION = r''' DOCUMENTATION = '''
module: na_ontap_nvme author: NetApp Ansible Team (@carchi8py) <ng-ansibleteam@netapp.com>
short_description: NetApp ONTAP Manage NVMe Service
description: description:
- Create/Delete NVMe Service - Create/Delete NVMe Service
extends_documentation_fragment: extends_documentation_fragment:
- netapp.na_ontap - netapp.na_ontap
author: module: na_ontap_nvme
- NetApp Ansible Team (@carchi8py) (ng-ansibleteam@netapp.com)
options: options:
state: state:
choices: ['present', 'absent']
description: description:
- Whether the specified NVMe should exist or not. - Whether the specified NVMe should exist or not.
type: str
choices: [ absent, present ]
default: present default: present
vserver: vserver:
description: description:
- Name of the vserver to use. - Name of the vserver to use.
type: str
required: true required: true
status_admin: status_admin:
description: description:
- Whether the status of NVMe should be up or down. - Whether the status of NVMe should be up or down
type: bool type: bool
short_description: "NetApp ONTAP Manage NVMe Service"
version_added: "2.8" version_added: "2.8"
''' '''
EXAMPLES = r''' EXAMPLES = """
- name: Create NVMe
na_ontap_nvme:
hostname: '{{ hostname }}'
username: '{{ username }}'
password: '{{ password }}'
vserver: '{{ vserver }}'
status_admin: no
state: present
- name: Modify NVMe - name: Create NVMe
na_ontap_nvme: na_ontap_nvme:
vserver: '{{ vserver }}'
hostname: '{{ hostname }}'
username: '{{ username }}'
password: '{{ password }}'
status_admin: yes
state: present state: present
status_admin: False
vserver: "{{ vserver }}"
hostname: "{{ hostname }}"
username: "{{ username }}"
password: "{{ password }}"
- name: Delete NVMe - name: Modify NVMe
na_ontap_nvme:
state: present
status_admin: True
vserver: "{{ vserver }}"
hostname: "{{ hostname }}"
username: "{{ username }}"
password: "{{ password }}"
- name: Delete NVMe
na_ontap_nvme: na_ontap_nvme:
hostname: '{{ hostname }}'
username: '{{ username }}'
password: '{{ password }}'
vserver: '{{ vserver }}'
state: absent state: absent
''' vserver: "{{ vserver }}"
hostname: "{{ hostname }}"
username: "{{ username }}"
password: "{{ password }}"
"""
RETURN = r''' RETURN = """
''' """
import traceback
from ansible.module_utils.basic import AnsibleModule from ansible.module_utils.basic import AnsibleModule
from ansible.module_utils._text import to_native from ansible.module_utils._text import to_native
import ansible.module_utils.netapp as netapp_utils import ansible.module_utils.netapp as netapp_utils
@ -86,15 +84,15 @@ class NetAppONTAPNVMe(object):
def __init__(self): def __init__(self):
self.argument_spec = netapp_utils.na_ontap_host_argument_spec() self.argument_spec = netapp_utils.na_ontap_host_argument_spec()
self.argument_spec.update( self.argument_spec.update(dict(
state=dict(type='str', default='present', choices=['absent', 'present']), state=dict(required=False, type='str', choices=['present', 'absent'], default='present'),
vserver=dict(type='str', required=True), vserver=dict(required=True, type='str'),
status_admin=dict(type='bool'), status_admin=dict(required=False, type='bool')
) ))
self.module = AnsibleModule( self.module = AnsibleModule(
argument_spec=self.argument_spec, argument_spec=self.argument_spec,
supports_check_mode=True, supports_check_mode=True
) )
self.na_helper = NetAppModule() self.na_helper = NetAppModule()
@ -122,7 +120,8 @@ class NetAppONTAPNVMe(object):
try: try:
result = self.server.invoke_successfully(nvme_get, enable_tunneling=False) result = self.server.invoke_successfully(nvme_get, enable_tunneling=False)
except netapp_utils.zapi.NaApiError as error: except netapp_utils.zapi.NaApiError as error:
self.module.fail_json(msg='Error fetching nvme info: %s' % to_native(error)) self.module.fail_json(msg='Error fetching nvme info: %s' % to_native(error),
exception=traceback.format_exc())
if result.get_child_by_name('num-records') and int(result.get_child_content('num-records')) >= 1: if result.get_child_by_name('num-records') and int(result.get_child_content('num-records')) >= 1:
attributes_list = result.get_child_by_name('attributes-list') attributes_list = result.get_child_by_name('attributes-list')
nvme_info = attributes_list.get_child_by_name('nvme-target-service-info') nvme_info = attributes_list.get_child_by_name('nvme-target-service-info')
@ -142,7 +141,8 @@ class NetAppONTAPNVMe(object):
self.server.invoke_successfully(nvme_create, enable_tunneling=True) self.server.invoke_successfully(nvme_create, enable_tunneling=True)
except netapp_utils.zapi.NaApiError as error: except netapp_utils.zapi.NaApiError as error:
self.module.fail_json(msg='Error creating nvme for vserver %s: %s' self.module.fail_json(msg='Error creating nvme for vserver %s: %s'
% (self.parameters['vserver'], to_native(error))) % (self.parameters['vserver'], to_native(error)),
exception=traceback.format_exc())
def delete_nvme(self): def delete_nvme(self):
""" """
@ -153,7 +153,8 @@ class NetAppONTAPNVMe(object):
self.server.invoke_successfully(nvme_delete, enable_tunneling=True) self.server.invoke_successfully(nvme_delete, enable_tunneling=True)
except netapp_utils.zapi.NaApiError as error: except netapp_utils.zapi.NaApiError as error:
self.module.fail_json(msg='Error deleting nvme for vserver %s: %s' self.module.fail_json(msg='Error deleting nvme for vserver %s: %s'
% (self.parameters['vserver'], to_native(error))) % (self.parameters['vserver'], to_native(error)),
exception=traceback.format_exc())
def modify_nvme(self, status=None): def modify_nvme(self, status=None):
""" """
@ -168,7 +169,8 @@ class NetAppONTAPNVMe(object):
self.server.invoke_successfully(nvme_modify, enable_tunneling=True) self.server.invoke_successfully(nvme_modify, enable_tunneling=True)
except netapp_utils.zapi.NaApiError as error: except netapp_utils.zapi.NaApiError as error:
self.module.fail_json(msg='Error modifying nvme for vserver %s: %s' self.module.fail_json(msg='Error modifying nvme for vserver %s: %s'
% (self.parameters['vserver'], to_native(error))) % (self.parameters['vserver'], to_native(error)),
exception=traceback.format_exc())
def apply(self): def apply(self):
""" """