ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

add optional use_tls parameter (#6154)

Browse source 
* add optional use_tls parameter

* add optional use_tls parameter

---------

Co-authored-by: Martin Helwig <prostep.helwig@extaccount.com>
This commit is contained in:
Martin Helwig 2023-03-14 23:01:59 +01:00 committed by GitHub
parent b97bee3fd6
commit 1dd86bcb55
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
changelogs/fragments/6154-znode-optional-tls.yml Normal file
View file

@ -0,0 +1,2 @@
minor_changes:
- znode module - optional ``use_tls`` parameter added for encrypted communication (https://github.com/ansible-collections/community.general/issues/6154).

10
plugins/modules/znode.py
View file

@ -72,6 +72,13 @@ options:
type: str type: str
required: false required: false
version_added: 5.8.0 version_added: 5.8.0
use_tls:
description:
- Using TLS/SSL or not.
type: bool
default: false
required: false
version_added: '6.5.0'
requirements: requirements:
- kazoo >= 2.1 - kazoo >= 2.1
- python >= 2.6 - python >= 2.6
@ -155,6 +162,7 @@ def main():
recursive=dict(default=False, type='bool'), recursive=dict(default=False, type='bool'),
auth_scheme=dict(default='digest', choices=['digest', 'sasl']), auth_scheme=dict(default='digest', choices=['digest', 'sasl']),
auth_credential=dict(type='str', no_log=True), auth_credential=dict(type='str', no_log=True),
use_tls=dict(default=False, type='bool'),
), ),
supports_check_mode=False supports_check_mode=False
) )
@ -208,7 +216,7 @@ def check_params(params):
class KazooCommandProxy(): class KazooCommandProxy():
def __init__(self, module): def __init__(self, module):
self.module = module self.module = module
self.zk = KazooClient(module.params['hosts']) self.zk = KazooClient(module.params['hosts'], use_ssl=module.params['use_tls'])
def absent(self): def absent(self):
return self._absent(self.module.params['name']) return self._absent(self.module.params['name'])