o NrfK@sBddlmZmZmZddlmZddZddZGdddZd S) )autherrorsutils) ServiceModecCsDdd}|durAt|dr d|vr|ddd|vr |ddt|dr2|d d kr2|d dt|d rAd |vrA|dd |dur_t|drP|ddt|d r_d |vr_|dd |dur}t|dr}d|vr}tdd|dDr}|dd|durd|vrt|dr|dd|drt|dr|ddr|ddt|dr|ddr|dd|dr~|d}t|dr|d r|d!d|d"dur|d#d|d$dur|d%d|d&dur|d'd|d(dur|d)d|d*dur|d+dt|dr5|d,dur(|d)d|d-dur5|d.dt|drV|d/durI|d0d|d1durV|d2dt|d3rj|d4durj|d5d3t|d6r~|d7dur~|d8d6|d9rt|dr|d9d:r|d;ddSdSdSdSdS).raise_version_error1.25ZMaxFailureRatiozUpdateConfig.max_failure_ratioZMonitorzUpdateConfig.monitorz1.28Z FailureActionrollbackz$UpdateConfig.failure_action rollback1.29ZOrderzUpdateConfig.orderrollback_configzRollbackConfig.orderz1.32ZPortscss|]}|dVqdS)Z PublishModeN)get).0pr r r (sz&_check_api_features..zEndpointSpec.Ports[].modeZ ForceUpdateZ force_updateZ Placementz1.30Z PlatformszPlacement.platformsz1.27Z PreferenceszPlacement.preferences ContainerSpecTTYzContainerSpec.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_ltrany)version task_template update_config endpoint_specrr container_specr r r _check_api_featuress                                   2rcCsz|}|dur;|D].\}}|dkr2d|vri|d<|dD]\}}|dur0||d|<q"q |dur:|||<q |S)Nr)copyitems)currentoverridemergedZts_keyZts_valueZcs_keyZcs_valuer r r _merge_task_templatecs r#c@seZdZed   dddZededdddZededd d Zededd d Z eddd dZ eded   dddZ eddddZ eded     dddZ dS)ServiceApiMixinz1.24Nc Cst|j|||| |d} i} |didd} | dur#td|r.t|ts.t|}t | \} }t || }|rA|| d<t |jdrP|pO|dd}||||t ||d }|durd||d <| durl| |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/createrImageNz,Missing mandatory Image key in ContainerSpecX-Registry-Authr Networks)NameLabels TaskTemplateModer' EndpointSpec UpdateConfigRollbackConfig)dataheadersT)r_version_urlrrZDockerException isinstancedictrrresolve_repository_nameget_config_headerrrpopconvert_service_networks_result _post_json)selfrnamelabelsmodernetworksendpoint_configrrurlr0imageregistry repo_name auth_headerr/r r r create_servicessB$    zServiceApiMixin.create_serviceservicecCsN|d|}i}|durt|jdrtd||d<||j||ddS)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}Nrz6insert_defaults is not supported in API version < 1.29ZinsertDefaultsparamsT)r2rrr1rrr9_get)r;rGinsert_defaultsrArJr r r inspect_services zServiceApiMixin.inspect_servicetaskcCs|d|}|||dS)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)r2r9rK)r;rNrAr r r inspect_tasks 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. rHT)r2_deleteZ_raise_for_status)r;rGrArespr r r remove_services   zServiceApiMixin.remove_servicecCs^d|rt|ndi}|durt|jdrtd||d<|d}||j||ddS) a" List services. Args: filters (dict): Filters to process on the nodes list. Valid filters: ``id``, ``name`` , ``label`` and ``mode``. Default: ``None``. status (bool): Include the service task count of running and desired tasks. Default: ``None``. Returns: A list of dictionaries containing data about each service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. filtersNz1.41z-status is not supported in API version < 1.41statusz /servicesrIT) rconvert_filtersrr1rrr2r9rK)r;rSrTrJrAr r r servicess zServiceApiMixin.servicesr Fallc Csd|||||||d} |d|} |j| | dd} | dur+||dddd 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. )detailsfollowstdoutstderrsince timestampstailz/services/{0}/logsT)rJstreamNSpecr*rrF)r2rKrMrZ_get_result_tty) r;rGrYrZr[r\r]r^r_Zis_ttyrJrAresr r r service_logs%s.! zServiceApiMixin.service_logscCs6d|rt|ndi}|d}||j||ddS)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. rSNz/tasksrIT)rrUr2r9rK)r;rSrJrAr r r tasksWs zServiceApiMixin.tasksc CsLt|j||| | | r d} t|jdrd} |j|| dd}ni}|d|}i}i}|dur5|dn||d<|durB|dn||d<|durXt|tsSt |}||d <n|d |d <t |d i||d <|d d i}|d d}|durt |\}}t ||}|r||d <|dur||d<n|d|d<| dur| |d<n|d|d<|durt|}t|jdr||d<n?||d d<n8t|jdr|d|d<n)|d ddur|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. TrN)rLraz/services/{0}/updater(r)r+r*rr%r&r-r.r r'r,r)r/rJr0)json)rr1rrrMr2rr3r4rr#rr5r6r8r:r9)r;rGrrr<r=r>rr?r@rZfetch_current_specrZinspect_defaultsr rAr/r0rrBrCrDrEZconverted_networksZcurrent_task_templateZcurrent_networksrQr r r update_serviceosz*                   zServiceApiMixin.update_service)NNNNNNNN)N)NN)FFFFrWFrXN) NNNNNNNNFN)__name__ __module__ __qualname__rminimum_versionrFZcheck_resourcerMrOrRrVrcrdrfr r r r r$rsB K   0 r$N) rrrtypesrrr#r$r r r r s  ^