cmueller/ansible
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

clean up documentation

Browse source
This commit is contained in:
Allen Sanabria 2016-08-03 12:50:16 -07:00
parent ab62c644bc
commit 123c70546e
1 changed files with 47 additions and 39 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

86
cloud/amazon/ec2_vpc_nat_gateway.py
View file

@ -17,7 +17,7 @@
DOCUMENTATION = ''' DOCUMENTATION = '''
--- ---
module: ec2_vpc_nat_gateway module: ec2_vpc_nat_gateway
short_description: Manage AWS VPC NAT Gateways short_description: Manage AWS VPC NAT Gateways.
description: description:
- Ensure the state of AWS VPC NAT Gateways based on their id, allocation and subnet ids. - Ensure the state of AWS VPC NAT Gateways based on their id, allocation and subnet ids.
version_added: "2.2" version_added: "2.2"
@ -25,7 +25,7 @@ requirements: [boto3, botocore]
options: options:
state: state:
description: description:
- Ensure NAT Gateway is present or absent - Ensure NAT Gateway is present or absent.
required: false required: false
default: "present" default: "present"
choices: ["present", "absent"] choices: ["present", "absent"]
@ -44,18 +44,18 @@ options:
allocation_id: allocation_id:
description: description:
- The id of the elastic IP allocation. If this is not passed and the - The id of the elastic IP allocation. If this is not passed and the
eip_address is not passed. An EIP is generated for this Nat Gateway eip_address is not passed. An EIP is generated for this NAT Gateway.
required: false required: false
default: None default: None
eip_address: eip_address:
description: description:
- The elasti ip address of the EIP you want attached to this Nat Gateway. - The elastic IP address of the EIP you want attached to this NAT Gateway.
If this is not passed and the allocation_id is not passed. If this is not passed and the allocation_id is not passed,
An EIP is generated for this Nat Gateway an EIP is generated for this NAT Gateway.
required: false required: false
if_exist_do_not_create: if_exist_do_not_create:
description: description:
- if a Nat Gateway exists already in the subnet_id, then do not create a new one. - if a NAT Gateway exists already in the subnet_id, then do not create a new one.
required: false required: false
default: false default: false
release_eip: release_eip:
@ -66,12 +66,12 @@ options:
default: true default: true
wait: wait:
description: description:
- Wait for operation to complete before returning - Wait for operation to complete before returning.
required: false required: false
default: false default: false
wait_timeout: wait_timeout:
description: description:
- How many seconds to wait for an operation to complete before timing out - How many seconds to wait for an operation to complete before timing out.
required: false required: false
default: 300 default: 300
client_token: client_token:
@ -93,7 +93,7 @@ extends_documentation_fragment:
EXAMPLES = ''' EXAMPLES = '''
# Note: These examples do not set authentication details, see the AWS Guide for details. # Note: These examples do not set authentication details, see the AWS Guide for details.
- name: Create new nat gateway with client token - name: Create new nat gateway with client token.
ec2_vpc_nat_gateway: ec2_vpc_nat_gateway:
state: present state: present
subnet_id: subnet-12345678 subnet_id: subnet-12345678
@ -102,7 +102,7 @@ EXAMPLES = '''
client_token: abcd-12345678 client_token: abcd-12345678
register: new_nat_gateway register: new_nat_gateway
- name: Create new nat gateway using an allocation-id - name: Create new nat gateway using an allocation-id.
ec2_vpc_nat_gateway: ec2_vpc_nat_gateway:
state: present state: present
subnet_id: subnet-12345678 subnet_id: subnet-12345678
@ -110,7 +110,7 @@ EXAMPLES = '''
region: ap-southeast-2 region: ap-southeast-2
register: new_nat_gateway register: new_nat_gateway
- name: Create new nat gateway, using an eip address and wait for available status - name: Create new nat gateway, using an EIP address and wait for available status.
ec2_vpc_nat_gateway: ec2_vpc_nat_gateway:
state: present state: present
subnet_id: subnet-12345678 subnet_id: subnet-12345678
@ -119,7 +119,7 @@ EXAMPLES = '''
region: ap-southeast-2 region: ap-southeast-2
register: new_nat_gateway register: new_nat_gateway
- name: Create new nat gateway and allocate new eip - name: Create new nat gateway and allocate new EIP.
ec2_vpc_nat_gateway: ec2_vpc_nat_gateway:
state: present state: present
subnet_id: subnet-12345678 subnet_id: subnet-12345678
@ -127,7 +127,7 @@ EXAMPLES = '''
region: ap-southeast-2 region: ap-southeast-2
register: new_nat_gateway register: new_nat_gateway
- name: Create new nat gateway and allocate new eip if a nat gateway does not yet exist in the subnet. - name: Create new nat gateway and allocate new EIP if a nat gateway does not yet exist in the subnet.
ec2_vpc_nat_gateway: ec2_vpc_nat_gateway:
state: present state: present
subnet_id: subnet-12345678 subnet_id: subnet-12345678
@ -136,7 +136,7 @@ EXAMPLES = '''
if_exist_do_not_create: true if_exist_do_not_create: true
register: new_nat_gateway register: new_nat_gateway
- name: Delete nat gateway using discovered nat gateways from facts module - name: Delete nat gateway using discovered nat gateways from facts module.
ec2_vpc_nat_gateway: ec2_vpc_nat_gateway:
state: absent state: absent
region: ap-southeast-2 region: ap-southeast-2
@ -146,7 +146,7 @@ EXAMPLES = '''
register: delete_nat_gateway_result register: delete_nat_gateway_result
with_items: "{{ gateways_to_remove.result }}" with_items: "{{ gateways_to_remove.result }}"
- name: Delete nat gateway and wait for deleted status - name: Delete nat gateway and wait for deleted status.
ec2_vpc_nat_gateway: ec2_vpc_nat_gateway:
state: absent state: absent
nat_gateway_id: nat-12345678 nat_gateway_id: nat-12345678
@ -154,7 +154,7 @@ EXAMPLES = '''
wait_timeout: 500 wait_timeout: 500
region: ap-southeast-2 region: ap-southeast-2
- name: Delete nat gateway and release EIP - name: Delete nat gateway and release EIP.
ec2_vpc_nat_gateway: ec2_vpc_nat_gateway:
state: absent state: absent
nat_gateway_id: nat-12345678 nat_gateway_id: nat-12345678
@ -179,7 +179,7 @@ subnet_id:
type: string type: string
sample: "subnet-12345" sample: "subnet-12345"
state: state:
description: The current state of the Nat Gateway. description: The current state of the NAT Gateway.
returned: In all cases. returned: In all cases.
type: string type: string
sample: "available" sample: "available"
@ -211,6 +211,7 @@ except ImportError:
import datetime import datetime
import random import random
import re
import time import time
from dateutil.tz import tzutc from dateutil.tz import tzutc
@ -262,6 +263,7 @@ DRY_RUN_ALLOCATION_UNCONVERTED = {
DRY_RUN_MSGS = 'DryRun Mode:' DRY_RUN_MSGS = 'DryRun Mode:'
def convert_to_lower(data): def convert_to_lower(data):
"""Convert all uppercase keys in dict with lowercase_ """Convert all uppercase keys in dict with lowercase_
@ -300,6 +302,7 @@ def convert_to_lower(data):
results[key] = val results[key] = val
return results return results
def get_nat_gateways(client, subnet_id=None, nat_gateway_id=None, def get_nat_gateways(client, subnet_id=None, nat_gateway_id=None,
states=None, check_mode=False): states=None, check_mode=False):
"""Retrieve a list of NAT Gateways """Retrieve a list of NAT Gateways
@ -381,9 +384,10 @@ def get_nat_gateways(client, subnet_id=None, nat_gateway_id=None,
return gateways_retrieved, err_msg, existing_gateways return gateways_retrieved, err_msg, existing_gateways
def wait_for_status(client, wait_timeout, nat_gateway_id, status, def wait_for_status(client, wait_timeout, nat_gateway_id, status,
check_mode=False): check_mode=False):
"""Wait for the Nat Gateway to reach a status """Wait for the NAT Gateway to reach a status
Args: Args:
client (botocore.client.EC2): Boto3 client client (botocore.client.EC2): Boto3 client
wait_timeout (int): Number of seconds to wait, until this timeout is reached. wait_timeout (int): Number of seconds to wait, until this timeout is reached.
@ -418,25 +422,25 @@ def wait_for_status(client, wait_timeout, nat_gateway_id, status,
] ]
Returns: Returns:
Tuple (bool, str, list) Tuple (bool, str, dict)
""" """
polling_increment_secs = 5 polling_increment_secs = 5
wait_timeout = time.time() + wait_timeout wait_timeout = time.time() + wait_timeout
status_achieved = False status_achieved = False
nat_gateway = list() nat_gateway = dict()
states = ['pending', 'failed', 'available', 'deleting', 'deleted'] states = ['pending', 'failed', 'available', 'deleting', 'deleted']
err_msg = "" err_msg = ""
while wait_timeout > time.time(): while wait_timeout > time.time():
try: try:
gws_retrieved, err_msg, nat_gateway = ( gws_retrieved, err_msg, nat_gateways = (
get_nat_gateways( get_nat_gateways(
client, nat_gateway_id=nat_gateway_id, client, nat_gateway_id=nat_gateway_id,
states=states, check_mode=check_mode states=states, check_mode=check_mode
) )
) )
if gws_retrieved and nat_gateway: if gws_retrieved and nat_gateways:
nat_gateway = nat_gateway[0] nat_gateway = nat_gateways[0]
if check_mode: if check_mode:
nat_gateway['state'] = status nat_gateway['state'] = status
@ -449,7 +453,7 @@ def wait_for_status(client, wait_timeout, nat_gateway_id, status,
break break
elif nat_gateway.get('state') == 'pending': elif nat_gateway.get('state') == 'pending':
if nat_gateway.has_key('failure_message'): if 'failure_message' in nat_gateway:
err_msg = nat_gateway.get('failure_message') err_msg = nat_gateway.get('failure_message')
status_achieved = False status_achieved = False
break break
@ -465,6 +469,7 @@ def wait_for_status(client, wait_timeout, nat_gateway_id, status,
return status_achieved, err_msg, nat_gateway return status_achieved, err_msg, nat_gateway
def gateway_in_subnet_exists(client, subnet_id, allocation_id=None, def gateway_in_subnet_exists(client, subnet_id, allocation_id=None,
check_mode=False): check_mode=False):
"""Retrieve all NAT Gateways for a subnet. """Retrieve all NAT Gateways for a subnet.
@ -472,7 +477,7 @@ def gateway_in_subnet_exists(client, subnet_id, allocation_id=None,
subnet_id (str): The subnet_id the nat resides in. subnet_id (str): The subnet_id the nat resides in.
Kwargs: Kwargs:
allocation_id (str): The eip Amazon identifier. allocation_id (str): The EIP Amazon identifier.
default = None default = None
Basic Usage: Basic Usage:
@ -526,6 +531,7 @@ def gateway_in_subnet_exists(client, subnet_id, allocation_id=None,
return gateways, allocation_id_exists return gateways, allocation_id_exists
def get_eip_allocation_id_by_address(client, eip_address, check_mode=False): def get_eip_allocation_id_by_address(client, eip_address, check_mode=False):
"""Release an EIP from your EIP Pool """Release an EIP from your EIP Pool
Args: Args:
@ -583,6 +589,7 @@ def get_eip_allocation_id_by_address(client, eip_address, check_mode=False):
return allocation_id, err_msg return allocation_id, err_msg
def allocate_eip_address(client, check_mode=False): def allocate_eip_address(client, check_mode=False):
"""Release an EIP from your EIP Pool """Release an EIP from your EIP Pool
Args: Args:
@ -623,6 +630,7 @@ def allocate_eip_address(client, check_mode=False):
return ip_allocated, err_msg, new_eip return ip_allocated, err_msg, new_eip
def release_address(client, allocation_id, check_mode=False): def release_address(client, allocation_id, check_mode=False):
"""Release an EIP from your EIP Pool """Release an EIP from your EIP Pool
Args: Args:
@ -657,6 +665,7 @@ def release_address(client, allocation_id, check_mode=False):
return ip_released return ip_released
def create(client, subnet_id, allocation_id, client_token=None, def create(client, subnet_id, allocation_id, client_token=None,
wait=False, wait_timeout=0, if_exist_do_not_create=False, wait=False, wait_timeout=0, if_exist_do_not_create=False,
check_mode=False): check_mode=False):
@ -743,11 +752,8 @@ def create(client, subnet_id, allocation_id, client_token=None,
) )
if success: if success:
err_msg = ( err_msg = (
'Nat gateway {0} created'.format(result['nat_gateway_id']) 'NAT gateway {0} created'.format(result['nat_gateway_id'])
) )
if check_mode:
result['nat_gateway_addresses'][0]['allocation_id'] = allocation_id
result['subnet_id'] = subnet_id
except botocore.exceptions.ClientError as e: except botocore.exceptions.ClientError as e:
if "IdempotentParameterMismatch" in e.message: if "IdempotentParameterMismatch" in e.message:
@ -762,16 +768,17 @@ def create(client, subnet_id, allocation_id, client_token=None,
return success, changed, err_msg, result return success, changed, err_msg, result
def pre_create(client, subnet_id, allocation_id=None, eip_address=None, def pre_create(client, subnet_id, allocation_id=None, eip_address=None,
if_exist_do_not_create=False, wait=False, wait_timeout=0, if_exist_do_not_create=False, wait=False, wait_timeout=0,
client_token=None, check_mode=False): client_token=None, check_mode=False):
"""Create an Amazon NAT Gateway. """Create an Amazon NAT Gateway.
Args: Args:
client (botocore.client.EC2): Boto3 client client (botocore.client.EC2): Boto3 client
subnet_id (str): The subnet_id the nat resides in. subnet_id (str): The subnet_id the nat resides in.
Kwargs: Kwargs:
allocation_id (str): The eip Amazon identifier. allocation_id (str): The EIP Amazon identifier.
default = None default = None
eip_address (str): The Elastic IP Address of the EIP. eip_address (str): The Elastic IP Address of the EIP.
default = None default = None
@ -829,7 +836,7 @@ def pre_create(client, subnet_id, allocation_id=None, eip_address=None,
changed = False changed = False
results = existing_gateways[0] results = existing_gateways[0]
err_msg = ( err_msg = (
'Nat Gateway {0} already exists in subnet_id {1}' 'NAT Gateway {0} already exists in subnet_id {1}'
.format( .format(
existing_gateways[0]['nat_gateway_id'], subnet_id existing_gateways[0]['nat_gateway_id'], subnet_id
) )
@ -864,7 +871,7 @@ def pre_create(client, subnet_id, allocation_id=None, eip_address=None,
changed = False changed = False
results = existing_gateways[0] results = existing_gateways[0]
err_msg = ( err_msg = (
'Nat Gateway {0} already exists in subnet_id {1}' 'NAT Gateway {0} already exists in subnet_id {1}'
.format( .format(
existing_gateways[0]['nat_gateway_id'], subnet_id existing_gateways[0]['nat_gateway_id'], subnet_id
) )
@ -878,6 +885,7 @@ def pre_create(client, subnet_id, allocation_id=None, eip_address=None,
return success, changed, err_msg, results return success, changed, err_msg, results
def remove(client, nat_gateway_id, wait=False, wait_timeout=0, def remove(client, nat_gateway_id, wait=False, wait_timeout=0,
release_eip=False, check_mode=False): release_eip=False, check_mode=False):
"""Delete an Amazon NAT Gateway. """Delete an Amazon NAT Gateway.
@ -944,7 +952,7 @@ def remove(client, nat_gateway_id, wait=False, wait_timeout=0,
changed = True changed = True
success = True success = True
err_msg = ( err_msg = (
'Nat gateway {0} is in a deleting state. Delete was successfull' 'NAT gateway {0} is in a deleting state. Delete was successfull'
.format(nat_gateway_id) .format(nat_gateway_id)
) )
@ -957,7 +965,7 @@ def remove(client, nat_gateway_id, wait=False, wait_timeout=0,
) )
if status_achieved: if status_achieved:
err_msg = ( err_msg = (
'Nat gateway {0} was deleted successfully' 'NAT gateway {0} was deleted successfully'
.format(nat_gateway_id) .format(nat_gateway_id)
) )
@ -969,10 +977,11 @@ def remove(client, nat_gateway_id, wait=False, wait_timeout=0,
release_address(client, allocation_id, check_mode=check_mode) release_address(client, allocation_id, check_mode=check_mode)
) )
if not eip_released: if not eip_released:
err_msg = "Failed to release eip %s".format(allocation_id) err_msg = "Failed to release EIP %s".format(allocation_id)
return success, changed, err_msg, results return success, changed, err_msg, results
def main(): def main():
argument_spec = ec2_argument_spec() argument_spec = ec2_argument_spec()
argument_spec.update(dict( argument_spec.update(dict(
@ -1067,4 +1076,3 @@ from ansible.module_utils.ec2 import *
if __name__ == '__main__': if __name__ == '__main__':
main() main()