U Ø–]»Iã@sDddlmZmZmZddlmZdd„Zdd„ZGdd„deƒZ d S) é)ÚauthÚerrorsÚutils)Ú ServiceModecCsJdd„}|dk r‚t |d¡r@d|kr.|ddƒd|kr@|ddƒt |d¡rd| d ¡d krd|d dƒt |d ¡r‚d |kr‚|dd ƒ|dk r¾t |d¡r |ddƒt |d ¡r¾d |kr¾|dd ƒ|dk rút |d¡rúd|krútdd„|dDƒƒrú|ddƒ|dk rFd|kr&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"¡dk rÖ|d#dƒ| d$¡dk rð|d%dƒ| d&¡dk r |d'dƒ| d(¡dk r$|d)dƒ| d*¡dk r>|d+dƒt |d¡r€| d,¡dk rf|d)dƒ| d-¡dk r€|d.dƒt |d¡rÂ| d/¡dk r¨|d0dƒ| d1¡dk rÂ|d2dƒt |d3¡rê| d4¡dk rê|d5d3ƒt |d6¡r| d7¡dk r|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 Ú *sz&_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| ¡}|dk rv| ¡D]\\}}|dkrdd|kr8i|d<|d ¡D]\}}|dk rD||d|<qDq|dk r|||<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¡} | dkrFt d¡‚|r\t|tƒs\t|ƒ}t   | ¡\} }t   || ¡}|r‚|| d<t   |jd¡r |pž| dd¡}||||t  |¡|d œ}|dk rÈ||d <| dk rØ| |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_serviceusJ$þ ÿ ú ÿzServiceApiMixin.create_serviceÚservicecCsN| d|¡}i}|dk r8t |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)r/rrr.rrr6Ú_get)r8rDÚinsert_defaultsr>rGrrr Ú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)r/r6rH)r8rKr>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. rET)r/Z_deleteZ_raise_for_status)r8rDr>Ú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 /servicesrFT©rZconvert_filtersr/r6rH©r8rOrGr>rrr Úservicess ÿ zServiceApiMixin.servicesr FéÚallc Csd|||||||dœ} | d|¡} |j| | dd} | dkrV| |¡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)rGÚstreamNÚSpecr'rrF)r/rHrJrZ_get_result_tty) r8rDrUrVrWrXrYrZr[Zis_ttyrGr>Úresrrr Ú service_logss0!ù ÿþþþþ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. rONz/tasksrFTrPrQrrr ÚtasksQs ÿ zServiceApiMixin.tasksc Cs\t|j||| | ƒ| r@d} t |jd¡r,d} |j|| dd}ni}| d|¡}i}i}|dkrj| d¡n||d<|dkr„| d¡n||d<|dk r°t|tƒs¦t |ƒ}||d <n| d ¡|d <t | d i¡|ƒ|d <|d  d i¡}| d d¡}|dk r"t   |¡\}}t   ||¡}|r"||d <|dk r6||d<n| d¡|d<| dk rX| |d<n| d¡|d<|dk r¢t |¡}t |jd¡r”||d<n ||d d<ntt |jd¡rÂ| d¡|d<nT|d  d¡dkr| d i¡}| d¡}|dkr| d¡}|dk r||d d<| dk r*| |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)rIr]z/services/{0}/updater%r&r(r'rr"r#r*r+r r$r)r)r,rGr-)Zjson)rr.rrrJr/rr0r1rr rr2r3r5r7r6)r8rDrrr9r:r;rr<r=rZfetch_current_specr Zinspect_defaultsrr>r,r-rr?r@rArBZconverted_networksZcurrent_task_templateZcurrent_networksrMrrr Úupdate_serviceisŠ*þÿþ    ÿ                  ÿzServiceApiMixin.update_service)NNNNNNNN)N)N)FFFFrSFrTN)N) NNNNNNNNFN)Ú__name__Ú __module__Ú __qualname__rZminimum_versionrCZcheck_resourcerJrLrNrRr_r`rarrrr r!tsXý K   þ0 ür!N) ÚrrrÚtypesrrr Úobjectr!rrrr Ús `