Vh!+ddlmZmZmZeZddlZddlmZ ddl m Z m Z ddl mZddlmZddlmZGdd eZy#e $rY%wxYw) )absolute_importdivisionprint_functionN)sleep)APIErrorNotFound) to_native) LooseVersion)AnsibleDockerClientcteZdZfdZdZddZdZdZdZddZ ddZ d Z dd Z d Z fd Zdd ZxZS)AnsibleDockerSwarmClientc ,tt| di|y)N)superr __init__)selfkwargs __class__s o/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/docker/plugins/module_utils/swarm.pyrz!AnsibleDockerSwarmClient.__init__s &6@@c |j}rI"7+v5   rc||j}||jd |j|}tjd }tj|}d |vrf|d jd rR|d d jd}|dk(r&|d d jdddxs|dd }n|dd }||dd <|S#t$r]}|jdk(r|jd|jdk(r|rYd}~y|jdt |zYd}~d}~wt $r}|jd|zYd}~d}~wwxYw)aj Returns Swarm node info as in 'docker node inspect' command about single node :param skip_missing: if True then function will return None instead of failing the task :param node_id: node ID or name, if None then method will try to get node_id of host module run on :return: Single node information structure NzFailed to get node information.r*DCannot inspect node: To inspect node execute module on Swarm Manageri*Error while reading from Swarm manager: %sError inspecting swarm node: %sFr ManagerStatusLeaderAddr:r9rr;) r$r inspect_noder status_coder Exceptionrrr getcountsplit)rr+ skip_missingr.r!r" count_colonsswarm_leader_ips rr-z)AnsibleDockerSwarmClient.get_node_inspectsn ?,,.G ? II7 8 ?))'):I::ie<JJx( i ')--h7 )9&AGGL 1$&/&@&H&N&NsTU&VWX&Y&x]fgo]pqw]xO&/&9&&AO.= (#F+/ U#% `a#% IIBYs^S T T ? II7#= > > ?s)C E1D2D22 E>EEcp |j}t jd}t j|}|S#t$rG}|jdk(r|jd|jdt |zYd}~yd}~wt $r}|jd|zYd}~d}~wwxYw)z Returns Swarm node info as in 'docker node inspect' command about all registered nodes :return: Structure with information about all nodes rCrDrENrFFr) nodesrrLrr rMrrr )rr.r!r"s rget_all_nodes_inspectz.AnsibleDockerSwarmClient.get_all_nodes_inspects ? I::ie<JJx(  U#% `a IIBYs^S T T ? II7#= > > ?s#A B5 =B  B5B00B5c(g}|j}|y|dk(r |D]}|j|dd|S|dk(r|D]}i}|jd|di|jd|ddi|jd|ddi|jd |d d id |vr6|d d d ur|jd d i|jd |d di|jd|dddi|j||Sy)a{ Returns list of nodes registered in Swarm :param output: Defines format of returned data :return: If 'output' is 'short' then return data is list of nodes hostnames registered in Swarm, if 'output' is 'long' then returns data is list of dict containing the attributes as in output of command 'docker node ls' Nshort DescriptionHostnamelongr,r;r< AvailabilitySpecrGrHT Reachability EngineVersionEngine)rVappendupdate)routput nodes_list nodes_inspectnode node_propertys rget_all_nodes_listz+AnsibleDockerSwarmClient.get_all_nodes_listsl 224   W % C!!$}"5j"AB C(%v % 1 " $$dDJ%78$$j$}2Ej2Q%RS$$hXw0G%HI$$nd6l>6R%ST"d*O,X6$>%,,h-=>!((/4;PQ_;`)ab$$otM7J87TUd7e%fg!!-0 1"rc0|j|ddS)NrYrZ)r-)rnodeids rget_node_name_by_idz,AnsibleDockerSwarmClient.get_node_name_by_ids$$V,];JGGrcZ|jtdkrytt|S)Nz2.7.0)docker_py_versionr rr get_unlock_key)rrs rrnz'AnsibleDockerSwarmClient.get_unlock_keys*  ! !L$9 9-tCEErc |j|}tjd}tj|}|S#t$r1}|dur|jdt|znYd}~yYd}~cd}~wt$r>}|j dk(r|jd|jd|zYd}~d}~wt $r}|jd|zYd}~d}~wwxYw)a9 Returns Swarm service info as in 'docker service inspect' command about single service :param service_id: service ID or name :param skip_missing: if True then function will return None instead of failing the task :return: Single service information structure FrENrCzJCannot inspect service: To inspect service execute module on Swarm Managerz"Error inspecting swarm service: %sr) inspect_servicerrr rrLrMrrr )r service_idrQ service_infor!r"s rget_service_inspectz,AnsibleDockerSwarmClient.get_service_inspects B// ;L::l?zz(+  u$ FSVWXY B#% fg II:S@ A A B II:S@ A A Bs/A C% "A66 C%4B;; C%C  C%)N)Nr9)NF)rX)F)__name__ __module__ __qualname__rr$r/r3r5r7rAr-rVrhrkrnrs __classcell__)rs@rr r sKA("H [ 4)V(%NHF rr ) __future__rrrtype __metaclass__rtimer docker.errorsrr ImportError+ansible.module_utils.common.text.convertersr Aansible_collections.community.docker.plugins.module_utils.versionr @ansible_collections.community.docker.plugins.module_utils.commonr r rrrrsR CB   0 BZ`2  s>AA