Vh@jddlmZmZmZeZdZdZdZddl Z ddl Z ddl m Z m Z ddlmZmZddlmZmZdd lmZdd lmZGd d eZGd deZdZdZedk(reyy#e$rYMwxYw))absolute_importdivisionprint_functiona module: docker_swarm short_description: Manage Swarm cluster description: - Create a new Swarm cluster. - Add/Remove nodes or managers to an existing cluster. extends_documentation_fragment: - community.docker.docker - community.docker.docker.docker_py_1_documentation - community.docker.attributes - community.docker.attributes.actiongroup_docker attributes: check_mode: support: full diff_mode: support: full idempotent: support: full options: advertise_addr: description: - Externally reachable address advertised to other nodes. - This can either be an address/port combination in the form V(192.168.1.1:4567), or an interface followed by a port number, like V(eth0:4567). - If the port number is omitted, the port number from the listen address is used. - If O(advertise_addr) is not specified, it will be automatically detected when possible. - Only used when swarm is initialised or joined. Because of this it is not considered for idempotency checking. type: str default_addr_pool: description: - Default address pool in CIDR format. - Only used when swarm is initialised. Because of this it is not considered for idempotency checking. - Requires API version >= 1.39. type: list elements: str subnet_size: description: - Default address pool subnet mask length. - Only used when swarm is initialised. Because of this it is not considered for idempotency checking. - Requires API version >= 1.39. type: int listen_addr: description: - Listen address used for inter-manager communication. - This can either be an address/port combination in the form V(192.168.1.1:4567), or an interface followed by a port number, like V(eth0:4567). - If the port number is omitted, the default swarm listening port is used. - Only used when swarm is initialised or joined. Because of this it is not considered for idempotency checking. type: str default: 0.0.0.0:2377 force: description: - Use with state V(present) to force creating a new Swarm, even if already part of one. - Use with state V(absent) to Leave the swarm even if this node is a manager. type: bool default: false state: description: - Set to V(present), to create/update a new cluster. - Set to V(join), to join an existing cluster. - Set to V(absent), to leave an existing cluster. - Set to V(remove), to remove an absent node from the cluster. Note that removing requires Docker SDK for Python >= 2.4.0. - M(community.docker.docker_node) can be used to demote a manager before removal. type: str default: present choices: - present - join - absent - remove node_id: description: - Swarm id of the node to remove. - Used with O(state=remove). type: str join_token: description: - Swarm token used to join a swarm cluster. - Used with O(state=join). - If this value is specified, the corresponding value in the return values will be censored by Ansible. This is a side-effect of this value not being logged. type: str remote_addrs: description: - Remote address of one or more manager nodes of an existing Swarm to connect to. - Used with O(state=join). type: list elements: str task_history_retention_limit: description: - Maximum number of tasks history stored. - Docker default value is V(5). type: int snapshot_interval: description: - Number of logs entries between snapshot. - Docker default value is V(10000). type: int keep_old_snapshots: description: - Number of snapshots to keep beyond the current snapshot. - Docker default value is V(0). type: int log_entries_for_slow_followers: description: - Number of log entries to keep around to sync up slow followers after a snapshot is created. type: int heartbeat_tick: description: - Amount of ticks (in seconds) between each heartbeat. - Docker default value is V(1) seconds. type: int election_tick: description: - Amount of ticks (in seconds) needed without a leader to trigger a new election. - Docker default value is V(10) seconds. type: int dispatcher_heartbeat_period: description: - The delay (in nanoseconds) for an agent to send a heartbeat to the dispatcher. - Docker default value is 5 seconds, which corresponds to a value of V(5000000000). type: int node_cert_expiry: description: - Automatic expiry for nodes certificates, given in nanoseconds. - Docker default value is 90 days, which corresponds to a value of V(7776000000000000). type: int name: description: - The name of the swarm. type: str labels: description: - User-defined key/value metadata. - Label operations in this module apply to the docker swarm cluster. Use M(community.docker.docker_node) module to add/modify/remove swarm node labels. - Requires API version >= 1.32. type: dict signing_ca_cert: description: - The desired signing CA certificate for all swarm node TLS leaf certificates, in PEM format. - This must not be a path to a certificate, but the contents of the certificate. - Requires API version >= 1.30. type: str signing_ca_key: description: - The desired signing CA key for all swarm node TLS leaf certificates, in PEM format. - This must not be a path to a key, but the contents of the key. - Requires API version >= 1.30. type: str ca_force_rotate: description: - An integer whose purpose is to force swarm to generate a new signing CA certificate and key, if none have been specified. - Docker default value is V(0). - Requires API version >= 1.30. type: int autolock_managers: description: - If set, generate a key and use it to lock data stored on the managers. - Docker default value is V(false). - M(community.docker.docker_swarm_info) can be used to retrieve the unlock key. type: bool rotate_worker_token: description: Rotate the worker join token. type: bool default: false rotate_manager_token: description: Rotate the manager join token. type: bool default: false data_path_addr: description: - Address or interface to use for data path traffic. - This can either be an address in the form V(192.168.1.1), or an interface, like V(eth0). - Only used when swarm is initialised or joined. Because of this it is not considered for idempotency checking. - Requires API version >= 1.30. type: str version_added: 2.5.0 data_path_port: description: - Port to use for data path traffic. - This needs to be a port number like V(9789). - Only used when swarm is initialised. Because of this it is not considered for idempotency checking. - Requires API version >= 1.40. type: int version_added: 3.1.0 requirements: - "L(Docker SDK for Python,https://docker-py.readthedocs.io/en/stable/) >= 1.10.0" - Docker API >= 1.25 author: - Thierry Bouvet (@tbouvet) - Piotr Wojciechowski (@WojciechowskiPiotr) a --- - name: Init a new swarm with default parameters community.docker.docker_swarm: state: present - name: Update swarm configuration community.docker.docker_swarm: state: present election_tick: 5 - name: Add nodes community.docker.docker_swarm: state: join advertise_addr: 192.168.1.2 join_token: SWMTKN-1--xxxxx remote_addrs: ['192.168.1.1:2377'] - name: Leave swarm for a node community.docker.docker_swarm: state: absent - name: Remove a swarm manager community.docker.docker_swarm: state: absent force: true - name: Remove node from swarm community.docker.docker_swarm: state: remove node_id: mynode - name: Init a new swarm with different data path interface community.docker.docker_swarm: state: present advertise_addr: eth0 data_path_addr: ens10 - name: Init a new swarm with a different data path port community.docker.docker_swarm: state: present data_path_port: 9789 a swarm_facts: description: Information about swarm. returned: success type: dict contains: JoinTokens: description: Tokens to connect to the Swarm. returned: success type: dict contains: Worker: description: - Token to join the cluster as a new *worker* node. - B(Note:) if this value has been specified as O(join_token), the value here will not be the token, but C(VALUE_SPECIFIED_IN_NO_LOG_PARAMETER). If you pass O(join_token), make sure your playbook/role does not depend on this return value! returned: success type: str example: SWMTKN-1--xxxxx Manager: description: - Token to join the cluster as a new *manager* node. - B(Note:) if this value has been specified as O(join_token), the value here will not be the token, but C(VALUE_SPECIFIED_IN_NO_LOG_PARAMETER). If you pass O(join_token), make sure your playbook/role does not depend on this return value! returned: success type: str example: SWMTKN-1--xxxxx UnlockKey: description: The swarm unlock-key if O(autolock_managers=true). returned: on success if O(autolock_managers=true) and swarm is initialised, or if O(autolock_managers) has changed. type: str example: SWMKEY-1-xxx actions: description: Provides the actions done on the swarm. returned: when action failed. type: list elements: str example: ['This cluster is already a swarm cluster'] N)DockerExceptionAPIError)DockerBaseClassRequestException)DifferenceTrackersanitize_labels)AnsibleDockerSwarmClient) to_nativec@eZdZfdZedZdZdZdZxZ S)TaskParametersctt| d|_d|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_yN)superr__init__advertise_addr listen_addr remote_addrs join_tokendata_path_addrdata_path_portsnapshot_intervaltask_history_retention_limitkeep_old_snapshotslog_entries_for_slow_followersheartbeat_tick election_tickdispatcher_heartbeat_periodnode_cert_expirynamelabels log_driversigning_ca_certsigning_ca_keyca_force_rotateautolock_managersrotate_worker_tokenrotate_manager_tokendefault_addr_pool subnet_size)self __class__s q/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/docker/plugins/modules/docker_swarm.pyrzTaskParameters.__init__=s nd,." """&,0)"&.2+"!+/( $  #"#!%#' $(!!%ct}|jjjD]!\}}||jvst |||#|j ||Sr)rmoduleparamsitems__dict__setattrupdate_parameters)clientresultkeyvalues r/from_ansible_paramsz"TaskParameters.from_ansible_params\s]! --..446 ,JCfoo%U+ ,   ( r0cz|d}|jdxs t}|j|jd|_|j|jd|_|jdxs t}|j|jd|_|jdxs t}|j |jd|_|j |jd |_|j|jd |_|j|jd |_|j|jd |_ |jd xs t}|j|jd|_ |jdxs t}|j|jd|_ |j |d|_ |j|jdxsi|_ d|dvr|dd|_yy)NSpecCAConfigNodeCertExpiry ForceRotate DispatcherHeartbeatPeriodRaftSnapshotIntervalKeepOldSnapshots HeartbeatTickLogEntriesForSlowFollowers ElectionTick OrchestrationTaskHistoryRetentionLimitEncryptionConfigAutoLockManagersNameLabels LogDriver TaskDefaults)getdictr!r'r rrrrrrr(r"r#r$)r- swarm_infospec ca_config dispatcherraft orchestrationencryption_configs r/update_from_swarm_infoz%TaskParameters.update_from_swarm_infofs&!HHZ(2DF  ($-MM2B$CD !    '#,==#?D XXl+5tv  + + 3/9~~>O/PD ,xx)46  ! ! )%)XX.@%AD "  " " *&*hh/A&BD #    &"&((?";D   . . 626((;W2XD /    %!%.!9D 1;TV  , , 40=0A0AB]0^D - HH%78BDF  ! ! )%6%:%:;M%ND " 99 V DI ;; ((8,2DK $~. .">2;?DO /r0ctddddddddd d d d d dd}t}|jD],\}}|j|dst||}|(|||<.|jdi||_y)Nrrrrrrr r!r"r#r%r&r'r(r$)rrrrrrr r!r"r#r%r&r'r(r$ supported)rSr4option_minimal_versionsgetattrcreate_swarm_specrU)r-r8assignr3destsourcer;s r/r7z TaskParameters.update_parameterss1)G3+K+)(E/-+-1# ""LLN %LD&11&9+FD&)E $t  % -F,,6v6 r0cB|jD]O}|dvr|j|dst||}|*t||}||k7s<|j|||Q|jr|jddd|j r|jddd|S)N) rrrrr)r*rUr+r,rrr] parameteractiver)TFr*)r5r_r`addr)r*)r-otherr8 differenceskr; other_values r/compare_to_activez TaskParameters.compare_to_actives HA''11!4[AD!$E}!%+K #U;G H  # # OO1T%O P  $ $ OO2d5O Qr0) __name__ __module__ __qualname__r staticmethodr<r[r7rn __classcell__r.s@r/rr<s- >(@T76r0rcTeZdZfdZdZdZdZdZdZdZ dZ d Z d Z xZ S) SwarmManagerctt| ||_||_|jj |_i|_|jjd|_ |jjd|_ |jjd|_ t|_ tj||_d|_y)Nstateforcenode_idF)rrvrr8results check_moderTr2r3rxryrzr rkrr< parameterscreated)r-r8r{r.s r/rzSwarmManager.__init__s lD*,  ++00]]))'2 ]]))'2 }}++I6 ,.(<?"& Y   KK  AIcNR S  sC F8#BF88 G2'G--G2c|jjr|jdjdy|js|j j |j j|j j|j jd}|j j|j j|d< |jjd i||jdjd|jj!ddd d|jd <y#t$r1}|jjdt|zYd}~d}~wwxYw) Nrz%This node is already part of a swarm.)rrrrrz"Can not join the Swarm Cluster: %sz"New node is added to swarm clusterjoinedTFrfrr^)r8check_if_swarm_noder{rr|r}rrrrr join_swarmrrr rkri)r-join_argumentsrs r/rzSwarmManager.joinBs* ;; * * , LL # * *+R S  $ < <"oo88#::"&//"@"@ N --937??3Q3Q/0 X& &&88 Y&&'KL XeD"& Y  X   !E RU!VWW Xs D55 E/>'E**E/c|jjs|jdjdy|js' |jj |j |jdjd|jjddd d |jd <y#t$r1}|jjdt|zYd}~d}~wwxYw) Nrz!This node is not part of a swarm.)ryz-This node can not leave the Swarm Cluster: %szNode has left the swarm clusterrrrrfTr) r8rr{rr| leave_swarmryrrr rkri)r-rs r/rzSwarmManager.leaveWs{{..0 LL # * *+N O  c ''djj'9 Y&&'HI X)L"& Y  c   !PS\]`Sa!abb cs&B99 C3'C..C3c|jjs|jjd |jj|jd}|s|jjd|j s2 |jj|j|j|jdjd|jjd d d d |jd <y#t $rYywxYw#t $r1}|jjdt|zYd}~d}~wwxYw)NzThis node is not a manager.)rz repeat_checkz?Can not remove the node. The status node is ready and not down.)rzryz2Can not remove the node from the Swarm Cluster: %srz#Node is removed from swarm cluster.rFTrfr)r8rrcheck_if_swarm_node_is_downrzrr| remove_noderyr r{rrkri)r- status_downrs r/rzSwarmManager.removeds{{113 KK  : ; ++AA$,,efAgK KK  ^ _ h '' DJJ'O Y&&'LM XtD"& Y    h   !UXabeXf!fgg hs)'D1D DD E'E  E)rorprqrrrrrrrrrrrsrts@r/rvrvs6$ (  % N'6'* ''r0rvc:|jjddk(S)Nrxr)r2r3)r8s r/_detect_remove_operationrzs ==   (H 44r0cLtdAidtddtddtddtddgd  d td d dtdddtdddtdddtddtddtddtddtddtddtddtddtdd td!d"tdd#tddd$tdd%td d&tdd'td d d(td d d)tddd*td}dd+ddgfdd,d&gfg}ttd-d./td-d0/td-d0/td-d0/td-1td-1td2td34td5d6/td5d6/td5d0/td7d8/9 }t|d|d:|;}t|jj d d | td djt|tj?Yd}~yd}~wt$rG}|jd@jt|tj?Yd}~yd}~wwxYw)BNrstr)typerrintrxrr)rrchoicesryboolF)rrrz 0.0.0.0:2377rlist)relementsrT)rno_logrrrrrrr r!r"r#rSr%r&r'r(rzr)r*r+r,rrz2.6.0z1.32)docker_py_versiondocker_api_versionz1.30)rz2.4.0zremove swarm nodes)r detect_usage usage_msgz4.0.0z1.39z6.0.0z1.40) r#r%r&r'r(r$remove_operationr+r,rrz1.10.0) argument_specsupports_check_mode required_ifmin_docker_versionr_)rr9rz(An unexpected docker error occurred: {0}) exceptionzhAn unexpected requests error occurred when Docker SDK for Python tried to talk to the docker daemon: {0}r^)rSrr r r2r3rv exit_jsonrrformatr traceback format_excr )rrr_r8r{es r/mainr~s\'''y:ab  .  e^< v6U40E*&*u%5 U+(,'7'&%)e$4 5)!"u #$ %&%('(t4)*%(+,F+-.% /0!fe<12"vu=34FU;56e$7M> &><89 (YK(K #g&Iw6Rg&Qw6R9'2%1* VT7vNg&Qg&Q$&# # 7 FFMM((2HfE.  & VW%' *'* w >EEiPQlS_h_s_s_u vv . v } }HIJK L**,  . ..s$ ;J L#=K L#=LL#__main__) __future__rrrr __metaclass__ DOCUMENTATIONEXAMPLESRETURNrr docker.errorsrr ImportError@ansible_collections.community.docker.plugins.module_utils.commonrr >ansible_collections.community.docker.plugins.module_utils.utilr r ?ansible_collections.community.docker.plugins.module_utils.swarmr +ansible.module_utils.common.text.convertersr rrvrrror^r0r/rsA@ D L* X' R  7  eAB_BJv'?v'r5M.` zFI   sA**A21A2