o 2.aI@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 FailureActionZrollbackz$UpdateConfig.failure_action rollback1.29ZOrderzUpdateConfig.orderrollback_configzRollbackConfig.orderz1.32ZPortscss|]}|dVqdS)Z PublishModeN)get).0prrr *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_specr r container_specrrr _check_api_featuress                                   2rcCsz|}|dur;|D].\}}|dkr2d|vri|d<|dD]\}}|dur0||d|<q"q |dur:|||<q |S)Nr)copyitems)currentoverrideZmergedZts_keyZts_valueZcs_keyZcs_valuerrr _merge_task_templatees 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_configrr urlr-imageregistry repo_name auth_headerr,rrr create_serviceusB$    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}Nr z6insert_defaults is not supported in API version < 1.29ZinsertDefaultsparamsT)r/rrr.rrr6_get)r8rDinsert_defaultsr>rGrrr 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)r/r6rH)r8rKr>rrr 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. rET)r/Z_deleteZ_raise_for_status)r8rDr>resprrr remove_services   zServiceApiMixin.remove_servicecC6d|rt|ndi}|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``. Returns: A list of dictionaries containing data about each service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. filtersNz /servicesrFTrZconvert_filtersr/r6rHr8rPrGr>rrr 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)rGstreamNSpecr'rrF)r/rHrJrZ_get_result_tty) r8rDrVrWrXrYrZr[r\Zis_ttyrGr>resrrr service_logss.! zServiceApiMixin.service_logscCrO)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. rPNz/tasksrFTrQrRrrr tasksQs 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. 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_serviceisz*                   zServiceApiMixin.update_service)NNNNNNNN)N)FFFFrTFrUN) NNNNNNNNFN)__name__ __module__ __qualname__rZminimum_versionrCZcheck_resourcerJrLrNrSr`rarbrrrr r!tsB K   0 r!N) rrrtypesrrr r!rrrr s  `