a T¥H„£-ìZã@sDddlmZmZmZddlmZdd„Zdd„ZGdd„deƒZ d S) é)ÚauthÚerrorsÚutils)Ú ServiceModecCsJdd„}|dur‚t |d¡r@d|vr.|ddƒd|vr@|ddƒt |d¡rd| d ¡d krd|d dƒt |d ¡r‚d |vr‚|dd ƒ|dur¾t |d¡r |ddƒt |d ¡r¾d |vr¾|dd ƒ|durút |d¡rúd|vrútdd„|dDƒƒrú|ddƒ|durFd|vr&t |d¡r&|ddƒ| d¡r‚t |d¡rZ|d d¡rZ|ddƒt |d¡r‚|d d¡r‚|ddƒ| d¡r| d¡}t |d¡r>| d ¡r¼|d!dƒ| d"¡durÖ|d#dƒ| d$¡durð|d%dƒ| d&¡dur |d'dƒ| d(¡dur$|d)dƒ| d*¡dur>|d+dƒt |d¡r€| d,¡durf|d)dƒ| d-¡dur€|d.dƒt |d¡rÂ| d/¡dur¨|d0dƒ| d1¡durÂ|d2dƒt |d3¡rê| d4¡durê|d5d3ƒt |d6¡r| d7¡dur|d8d6ƒ| d9¡rFt |d¡rF|d9 d:¡rF|d;dƒdS).raise_version_errorú1.25ZMaxFailureRatiozUpdateConfig.max_failure_ratioZMonitorzUpdateConfig.monitorz1.28Z FailureActionZrollbackz$UpdateConfig.failure_action rollbackú1.29ZOrderzUpdateConfig.orderÚrollback_configzRollbackConfig.orderz1.32ZPortscss|]}| d¡VqdS)Z PublishModeN)Úget)Ú.0Úprrr Ú *óz&_check_api_features..zEndpointSpec.Ports[].modeZ ForceUpdateZ force_updateZ Placementz1.30Z PlatformszPlacement.platformsz1.27Z PreferenceszPlacement.preferencesÚ ContainerSpecÚTTYzContainerSpec.ttyZHostnamezContainerSpec.hostnameZHostszContainerSpec.hostsZGroupszContainerSpec.groupsZ DNSConfigzContainerSpec.dns_configZ HealthcheckzContainerSpec.healthcheckZReadOnlyZ StopSignalzContainerSpec.stop_signalZConfigszContainerSpec.configsZ PrivilegeszContainerSpec.privilegesz1.35Z IsolationzContainerSpec.isolationz1.38ZInitzContainerSpec.initZ ResourcesZGenericResourceszResources.generic_resources)rÚ version_ltrÚany)ÚversionÚ task_templateÚ update_configÚ endpoint_specr r Úcontainer_specrrr Ú_check_api_featuress    ÿ        ÿ                    rcCsz| ¡}|durv| ¡D]\\}}|dkrdd|vr8i|d<|d ¡D]\}}|durD||d|<qDq|dur|||<q|S)Nr)ÚcopyÚitems)ÚcurrentÚoverrideZmergedZts_keyZts_valueZcs_keyZcs_valuerrr Ú_merge_task_templatees r!c @sÚeZdZe d¡ddd„ƒZe d¡e d¡ddd„ƒƒZe d¡e d¡d d „ƒƒZe d¡e d¡d d „ƒƒZ e d¡dd d„ƒZ e d¡e d¡ddd„ƒƒZ e d¡ddd„ƒZ e d¡e d¡ddd„ƒƒZ dS)ÚServiceApiMixinz1.24Nc Csðt|j|||| ƒ| d¡} i} | di¡ dd¡} | durFt d¡‚|r\t|tƒs\t|ƒ}t   | ¡\} }t   || ¡}|r‚|| d<t   |jd¡r |pž| dd¡}||||t  |¡|d œ}|durÈ||d <| durØ| |d <| |j| || d d ¡S)a Create a service. Args: task_template (TaskTemplate): Specification of the task to start as part of the new service. name (string): User-defined name for the service. Optional. labels (dict): A map of labels to associate with the service. Optional. mode (ServiceMode): Scheduling mode for the service (replicated or global). Defaults to replicated. update_config (UpdateConfig): Specification for the update strategy of the service. Default: ``None`` rollback_config (RollbackConfig): Specification for the rollback strategy of the service. Default: ``None`` networks (:py:class:`list`): List of network names or IDs or :py:class:`~docker.types.NetworkAttachmentConfig` to attach the service to. Default: ``None``. endpoint_spec (EndpointSpec): Properties that can be configured to access and load balance a service. Default: ``None``. Returns: A dictionary containing an ``ID`` key for the newly created service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. z/services/createrÚImageNz,Missing mandatory Image key in ContainerSpecúX-Registry-Authr ÚNetworks)ÚNameÚLabelsÚ TaskTemplateÚModer%Ú EndpointSpecÚ UpdateConfigÚRollbackConfig)ÚdataÚheadersT)rÚ_versionÚ_urlrrZDockerExceptionÚ isinstanceÚdictrrÚresolve_repository_nameÚget_config_headerrrÚpopÚconvert_service_networksÚ_resultÚ _post_json)ÚselfrÚnameÚlabelsÚmoderÚnetworksÚendpoint_configrr Úurlr.ÚimageÚregistryÚ repo_nameÚ auth_headerr-rrr Úcreate_serviceusB$ þ ÿ ú ÿzServiceApiMixin.create_serviceÚservicecCsN| d|¡}i}|dur8t |jd¡r0t d¡‚||d<| |j||dd¡S)aú Return information about a service. Args: service (str): Service name or ID. insert_defaults (boolean): If true, default values will be merged into the service inspect output. Returns: (dict): A dictionary of the server-side representation of the service, including all relevant properties. Raises: :py:class:`docker.errors.APIError` If the server returns an error. ú /services/{0}Nr z6insert_defaults is not supported in API version < 1.29ZinsertDefaults©ÚparamsT)r0rrr/rrr7Ú_get)r9rEÚinsert_defaultsr?rHrrr Úinspect_serviceÁs ÿzServiceApiMixin.inspect_serviceÚtaskcCs| d|¡}| | |¡d¡S)a Retrieve information about a task. Args: task (str): Task ID Returns: (dict): Information about the task. Raises: :py:class:`docker.errors.APIError` If the server returns an error. z /tasks/{0}T)r0r7rI)r9rLr?rrr Ú inspect_taskßs zServiceApiMixin.inspect_taskcCs$| d|¡}| |¡}| |¡dS)a Stop and remove a service. Args: service (str): Service name or ID Returns: ``True`` if successful. Raises: :py:class:`docker.errors.APIError` If the server returns an error. rFT)r0Ú_deleteZ_raise_for_status)r9rEr?Úresprrr Úremove_serviceòs   zServiceApiMixin.remove_servicecCs6d|rt |¡ndi}| d¡}| |j||dd¡S)a§ List services. Args: filters (dict): Filters to process on the nodes list. Valid filters: ``id``, ``name`` , ``label`` and ``mode``. Default: ``None``. Returns: A list of dictionaries containing data about each service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. ÚfiltersNz /servicesrGT©rZconvert_filtersr0r7rI©r9rQrHr?rrr Úservicessÿ zServiceApiMixin.servicesr FéÚallc Csd|||||||dœ} | d|¡} |j| | dd} | durV| |¡ddd d d ¡} | d| | ¡S) ar Get log stream for a service. Note: This endpoint works only for services with the ``json-file`` or ``journald`` logging drivers. Args: service (str): ID or name of the service details (bool): Show extra details provided to logs. Default: ``False`` follow (bool): Keep connection open to read logs as they are sent by the Engine. Default: ``False`` stdout (bool): Return logs from ``stdout``. Default: ``False`` stderr (bool): Return logs from ``stderr``. Default: ``False`` since (int): UNIX timestamp for the logs staring point. Default: 0 timestamps (bool): Add timestamps to every log line. tail (string or int): Number of log lines to be returned, counting from the current end of the logs. Specify an integer or ``'all'`` to output all log lines. Default: ``all`` is_tty (bool): Whether the service's :py:class:`ContainerSpec` enables the TTY option. If omitted, the method will query the Engine for the information, causing an additional roundtrip. Returns (generator): Logs for the service. )ÚdetailsÚfollowÚstdoutÚstderrÚsinceÚ timestampsÚtailz/services/{0}/logsT)rHÚstreamNÚSpecr(rrF)r0rIrKrZ_get_result_tty) r9rErWrXrYrZr[r\r]Zis_ttyrHr?Úresrrr Ú service_logss.!ù ÿþþþþzServiceApiMixin.service_logscCs6d|rt |¡ndi}| d¡}| |j||dd¡S)a» Retrieve a list of tasks. Args: filters (dict): A map of filters to process on the tasks list. Valid filters: ``id``, ``name``, ``service``, ``node``, ``label`` and ``desired-state``. Returns: (:py:class:`list`): List of task dictionaries. Raises: :py:class:`docker.errors.APIError` If the server returns an error. rQNz/tasksrGTrRrSrrr ÚtasksQsÿ zServiceApiMixin.tasksc Cs\t|j||| | ƒ| r@d} t |jd¡r,d} |j|| dd}ni}| d|¡}i}i}|durj| d¡n||d<|dur„| d¡n||d<|dur°t|tƒs¦t |ƒ}||d <n| d ¡|d <t | d i¡|ƒ|d <|d  d i¡}| d d¡}|dur"t   |¡\}}t   ||¡}|r"||d <|dur6||d<n| d¡|d<| durX| |d<n| d¡|d<|dur¢t |¡}t |jd¡r”||d<n ||d d<ntt |jd¡rÂ| d¡|d<nT|d  d¡dur| d i¡}| d¡}|dur| d¡}|dur||d d<| dur*| |d<n| d¡|d<|j||d|i|d}|j|ddS)a€ Update a service. Args: service (string): A service identifier (either its name or service ID). version (int): The version number of the service object being updated. This is required to avoid conflicting writes. task_template (TaskTemplate): Specification of the updated task to start as part of the service. name (string): New name for the service. Optional. labels (dict): A map of labels to associate with the service. Optional. mode (ServiceMode): Scheduling mode for the service (replicated or global). Defaults to replicated. update_config (UpdateConfig): Specification for the update strategy of the service. Default: ``None``. rollback_config (RollbackConfig): Specification for the rollback strategy of the service. Default: ``None`` networks (:py:class:`list`): List of network names or IDs or :py:class:`~docker.types.NetworkAttachmentConfig` to attach the service to. Default: ``None``. endpoint_spec (EndpointSpec): Properties that can be configured to access and load balance a service. Default: ``None``. fetch_current_spec (boolean): Use the undefined settings from the current specification of the service. Default: ``False`` Returns: A dictionary containing a ``Warnings`` key. Raises: :py:class:`docker.errors.APIError` If the server returns an error. Tr N)rJr_z/services/{0}/updater&r'r)r(rr#r$r+r,r r%r*r)r-rHr.)Zjson)rr/rrrKr0rr1r2rr!rr3r4r6r8r7)r9rErrr:r;r<rr=r>rZfetch_current_specr Zinspect_defaultsrr?r-r.rr@rArBrCZconverted_networksZcurrent_task_templateZcurrent_networksrOrrr Úupdate_serviceisz* þÿþ    ÿ                   ÿzServiceApiMixin.update_service)NNNNNNNN)N)N)FFFFrUFrVN)N) NNNNNNNNFN)Ú__name__Ú __module__Ú __qualname__rZminimum_versionrDZcheck_resourcerKrMrPrTrarbrcrrrr r"ts@ý K   þ0 ür"N) ÚrrrÚtypesrrr!Úobjectr"rrrr Ús `