mirror of
https://github.com/ansible-collections/community.general.git
synced 2025-07-23 05:10:22 -07:00
Adds traffic group and fixes (#33502)
Adds the traffic group param. Adds conventions for updated f5 standards
This commit is contained in:
parent
00bf4ee210
commit
9f544cf926
2 changed files with 82 additions and 16 deletions
|
@ -109,6 +109,12 @@ options:
|
||||||
required: False
|
required: False
|
||||||
default: 'Common'
|
default: 'Common'
|
||||||
version_added: 2.5
|
version_added: 2.5
|
||||||
|
traffic_group:
|
||||||
|
description:
|
||||||
|
- The traffic group for the virtual address. When creating a new address,
|
||||||
|
if this value is not specified, the default of C(/Common/traffic-group-1)
|
||||||
|
will be used.
|
||||||
|
version_added: 2.5
|
||||||
notes:
|
notes:
|
||||||
- Requires the f5-sdk Python package on the host. This is as easy as pip
|
- Requires the f5-sdk Python package on the host. This is as easy as pip
|
||||||
install f5-sdk.
|
install f5-sdk.
|
||||||
|
@ -214,12 +220,13 @@ class Parameters(AnsibleF5Parameters):
|
||||||
'connectionLimit': 'connection_limit',
|
'connectionLimit': 'connection_limit',
|
||||||
'serverScope': 'advertise_route',
|
'serverScope': 'advertise_route',
|
||||||
'mask': 'netmask',
|
'mask': 'netmask',
|
||||||
'arp': 'arp_state'
|
'arp': 'arp_state',
|
||||||
|
'trafficGroup': 'traffic_group',
|
||||||
}
|
}
|
||||||
|
|
||||||
updatables = [
|
updatables = [
|
||||||
'use_route_advertisement', 'auto_delete', 'icmp_echo', 'connection_limit',
|
'use_route_advertisement', 'auto_delete', 'icmp_echo', 'connection_limit',
|
||||||
'arp_state', 'enabled', 'advertise_route'
|
'arp_state', 'enabled', 'advertise_route', 'traffic_group'
|
||||||
]
|
]
|
||||||
|
|
||||||
returnables = [
|
returnables = [
|
||||||
|
@ -229,9 +236,14 @@ class Parameters(AnsibleF5Parameters):
|
||||||
|
|
||||||
api_attributes = [
|
api_attributes = [
|
||||||
'routeAdvertisement', 'autoDelete', 'icmpEcho', 'connectionLimit',
|
'routeAdvertisement', 'autoDelete', 'icmpEcho', 'connectionLimit',
|
||||||
'advertiseRoute', 'arp', 'mask', 'enabled', 'serverScope'
|
'advertiseRoute', 'arp', 'mask', 'enabled', 'serverScope', 'trafficGroup'
|
||||||
]
|
]
|
||||||
|
|
||||||
|
def _fqdn_name(self, value):
|
||||||
|
if value is not None and not value.startswith('/'):
|
||||||
|
return '/{0}/{1}'.format(self.partition, value)
|
||||||
|
return value
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def advertise_route(self):
|
def advertise_route(self):
|
||||||
if self._values['advertise_route'] is None:
|
if self._values['advertise_route'] is None:
|
||||||
|
@ -317,6 +329,19 @@ class Parameters(AnsibleF5Parameters):
|
||||||
else:
|
else:
|
||||||
return self._values['state']
|
return self._values['state']
|
||||||
|
|
||||||
|
@property
|
||||||
|
def traffic_group(self):
|
||||||
|
if self._values['traffic_group'] is None:
|
||||||
|
return None
|
||||||
|
else:
|
||||||
|
result = self._fqdn_name(self._values['traffic_group'])
|
||||||
|
if result.startswith('/Common/'):
|
||||||
|
return result
|
||||||
|
else:
|
||||||
|
raise F5ModuleError(
|
||||||
|
"Traffic groups can only exist in /Common"
|
||||||
|
)
|
||||||
|
|
||||||
def to_return(self):
|
def to_return(self):
|
||||||
result = {}
|
result = {}
|
||||||
for returnable in self.returnables:
|
for returnable in self.returnables:
|
||||||
|
@ -336,12 +361,43 @@ class Parameters(AnsibleF5Parameters):
|
||||||
return result
|
return result
|
||||||
|
|
||||||
|
|
||||||
|
class Changes(Parameters):
|
||||||
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
class Difference(object):
|
||||||
|
def __init__(self, want, have=None):
|
||||||
|
self.want = want
|
||||||
|
self.have = have
|
||||||
|
|
||||||
|
def compare(self, param):
|
||||||
|
try:
|
||||||
|
result = getattr(self, param)
|
||||||
|
return result
|
||||||
|
except AttributeError:
|
||||||
|
return self.__default(param)
|
||||||
|
|
||||||
|
def __default(self, param):
|
||||||
|
attr1 = getattr(self.want, param)
|
||||||
|
try:
|
||||||
|
attr2 = getattr(self.have, param)
|
||||||
|
if attr1 != attr2:
|
||||||
|
return attr1
|
||||||
|
except AttributeError:
|
||||||
|
return attr1
|
||||||
|
|
||||||
|
@property
|
||||||
|
def traffic_group(self):
|
||||||
|
if self.want.traffic_group != self.have.traffic_group:
|
||||||
|
return self.want.traffic_group
|
||||||
|
|
||||||
|
|
||||||
class ModuleManager(object):
|
class ModuleManager(object):
|
||||||
def __init__(self, client):
|
def __init__(self, client):
|
||||||
self.client = client
|
self.client = client
|
||||||
self.have = None
|
self.have = None
|
||||||
self.want = Parameters(self.client.module.params)
|
self.want = Parameters(self.client.module.params)
|
||||||
self.changes = Parameters()
|
self.changes = Changes()
|
||||||
|
|
||||||
def _set_changed_options(self):
|
def _set_changed_options(self):
|
||||||
changed = {}
|
changed = {}
|
||||||
|
@ -349,18 +405,23 @@ class ModuleManager(object):
|
||||||
if getattr(self.want, key) is not None:
|
if getattr(self.want, key) is not None:
|
||||||
changed[key] = getattr(self.want, key)
|
changed[key] = getattr(self.want, key)
|
||||||
if changed:
|
if changed:
|
||||||
self.changes = Parameters(changed)
|
self.changes = Changes(changed)
|
||||||
|
|
||||||
def _update_changed_options(self):
|
def _update_changed_options(self):
|
||||||
changed = {}
|
diff = Difference(self.want, self.have)
|
||||||
for key in Parameters.updatables:
|
updatables = Parameters.updatables
|
||||||
if getattr(self.want, key) is not None:
|
changed = dict()
|
||||||
attr1 = getattr(self.want, key)
|
for k in updatables:
|
||||||
attr2 = getattr(self.have, key)
|
change = diff.compare(k)
|
||||||
if attr1 != attr2:
|
if change is None:
|
||||||
changed[key] = attr1
|
continue
|
||||||
|
else:
|
||||||
|
if isinstance(change, dict):
|
||||||
|
changed.update(change)
|
||||||
|
else:
|
||||||
|
changed[k] = change
|
||||||
if changed:
|
if changed:
|
||||||
self.changes = Parameters(changed)
|
self.changes = Changes(changed)
|
||||||
return True
|
return True
|
||||||
return False
|
return False
|
||||||
|
|
||||||
|
@ -446,6 +507,8 @@ class ModuleManager(object):
|
||||||
|
|
||||||
def create(self):
|
def create(self):
|
||||||
self._set_changed_options()
|
self._set_changed_options()
|
||||||
|
if self.want.traffic_group is None:
|
||||||
|
self.want.update({'traffic_group': '/Common/traffic-group-1'})
|
||||||
if self.client.check_mode:
|
if self.client.check_mode:
|
||||||
return True
|
return True
|
||||||
self.create_on_device()
|
self.create_on_device()
|
||||||
|
@ -513,7 +576,8 @@ class ArgumentSpec(object):
|
||||||
),
|
),
|
||||||
use_route_advertisement=dict(
|
use_route_advertisement=dict(
|
||||||
type='bool'
|
type='bool'
|
||||||
)
|
),
|
||||||
|
traffic_group=dict()
|
||||||
)
|
)
|
||||||
self.f5_product_name = 'bigip'
|
self.f5_product_name = 'bigip'
|
||||||
|
|
||||||
|
|
|
@ -15,21 +15,23 @@ if sys.version_info < (2, 7):
|
||||||
raise SkipTest("F5 Ansible modules require Python >= 2.7")
|
raise SkipTest("F5 Ansible modules require Python >= 2.7")
|
||||||
|
|
||||||
from ansible.compat.tests import unittest
|
from ansible.compat.tests import unittest
|
||||||
from ansible.compat.tests.mock import patch, Mock
|
from ansible.compat.tests.mock import Mock
|
||||||
|
from ansible.compat.tests.mock import patch
|
||||||
from ansible.module_utils.f5_utils import AnsibleF5Client
|
from ansible.module_utils.f5_utils import AnsibleF5Client
|
||||||
from units.modules.utils import set_module_args
|
|
||||||
|
|
||||||
try:
|
try:
|
||||||
from library.bigip_virtual_address import Parameters
|
from library.bigip_virtual_address import Parameters
|
||||||
from library.bigip_virtual_address import ModuleManager
|
from library.bigip_virtual_address import ModuleManager
|
||||||
from library.bigip_virtual_address import ArgumentSpec
|
from library.bigip_virtual_address import ArgumentSpec
|
||||||
from ansible.module_utils.f5_utils import iControlUnexpectedHTTPError
|
from ansible.module_utils.f5_utils import iControlUnexpectedHTTPError
|
||||||
|
from test.unit.modules.utils import set_module_args
|
||||||
except ImportError:
|
except ImportError:
|
||||||
try:
|
try:
|
||||||
from ansible.modules.network.f5.bigip_virtual_address import Parameters
|
from ansible.modules.network.f5.bigip_virtual_address import Parameters
|
||||||
from ansible.modules.network.f5.bigip_virtual_address import ModuleManager
|
from ansible.modules.network.f5.bigip_virtual_address import ModuleManager
|
||||||
from ansible.modules.network.f5.bigip_virtual_address import ArgumentSpec
|
from ansible.modules.network.f5.bigip_virtual_address import ArgumentSpec
|
||||||
from ansible.module_utils.f5_utils import iControlUnexpectedHTTPError
|
from ansible.module_utils.f5_utils import iControlUnexpectedHTTPError
|
||||||
|
from units.modules.utils import set_module_args
|
||||||
except ImportError:
|
except ImportError:
|
||||||
raise SkipTest("F5 Ansible modules require the f5-sdk Python library")
|
raise SkipTest("F5 Ansible modules require the f5-sdk Python library")
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue