o q_aY5@sddlZddlmZmZddlmZmZmZmZddl m Z m Z Gddde Z Gdd d e Z gd Zgd Zgd Zgd ZddZdS)N)create_unexpected_kwargs_errorInvalidArgument) TaskTemplate ContainerSpec Placement ServiceMode)Model Collectionc@s^eZdZdZdZeddZeddZddZdd d Z d d Z ddZ ddZ ddZ d S)Servicez A service.ZIDcCs|jddS)zThe service's name.SpecName)attrsselfr8/usr/lib/python3/dist-packages/docker/models/services.pyname sz Service.namecCs|jddS)z The version number of the service. If this is not the same as the server, the :py:meth:`update` function will not work and you will need to call :py:meth:`reload` before calling it again. ZVersionZIndex)rgetrrrrversionszService.versioncCs|jj|jS)z Stop and remove the service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. )clientapiZremove_serviceidrrrrremoveszService.removeNcCs&|duri}|j|d<|jjj|dS)a List the tasks in this service. Args: filters (dict): A map of filters to process on the tasks list. Valid filters: ``id``, ``name``, ``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. Nservice)filters)rrrtasks)rrrrrr#s z Service.taskscKsd|vr|jddd}|d|d<|ddur/|jdd}t|dd }|d |d<td |}|jjj|j|jfi|S) a) Update a service's configuration. Similar to the ``docker service update`` command. Takes the same parameters as :py:meth:`~ServiceCollection.create`. Raises: :py:class:`docker.errors.APIError` If the server returns an error. imager rrZImage force_updateTZ ForceUpdaterrupdate) rrint_get_create_service_kwargsrrupdate_servicerr)rkwargsspec task_templateZ current_value create_kwargsrrrr8s    zService.updatecKs6|jddddd}|jjj|jfd|i|S)a Get log stream for the service. Note: This method works only for services with the ``json-file`` or ``journald`` logging drivers. Args: 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`` Returns: generator: Logs for the service. r rrZTTYFis_tty)rrrrZ service_logsr)rr#r'rrrlogsUsz Service.logscCsBd|jddvrtdtd|}|jjj|j|j|ddS)z Scale service container. Args: replicas (int): The number of containers that should be running. Returns: bool: ``True`` if successful. ZGlobalr ZModezCannot scale a global containerZ replicatedT)modefetch_current_spec) rkeysrrrrr"rr)rZreplicasZ service_moderrrscalers  z Service.scalecCs|jdddS)z Force update the service even if no changes require it. Returns: bool: ``True`` if successful. T)rr*)rrrrrrszService.force_updateN)__name__ __module__ __qualname____doc__Z id_attributepropertyrrrrrr(r,rrrrrr s    r c@s0eZdZdZeZd ddZd ddZddZdS) ServiceCollectionzServices on the Docker server.NcKs8||d<||d<td|}|jjjdi|}||S)a1 Create a service. Similar to the ``docker service create`` command. Args: image (str): The image name to use for the containers. command (list of str or str): Command to run. args (list of str): Arguments to the command. constraints (list of str): :py:class:`~docker.types.Placement` constraints. preferences (list of tuple): :py:class:`~docker.types.Placement` preferences. maxreplicas (int): :py:class:`~docker.types.Placement` maxreplicas or (int) representing maximum number of replicas per node. platforms (list of tuple): A list of platform constraints expressed as ``(arch, os)`` tuples. container_labels (dict): Labels to apply to the container. endpoint_spec (EndpointSpec): Properties that can be configured to access and load balance a service. Default: ``None``. env (list of str): Environment variables, in the form ``KEY=val``. hostname (string): Hostname to set on the container. init (boolean): Run an init inside the container that forwards signals and reaps processes isolation (string): Isolation technology used by the service's containers. Only used for Windows containers. labels (dict): Labels to apply to the service. log_driver (str): Log driver to use for containers. log_driver_options (dict): Log driver options. mode (ServiceMode): Scheduling mode for the service. Default:``None`` mounts (list of str): Mounts for the containers, in the form ``source:target:options``, where options is either ``ro`` or ``rw``. name (str): Name to give to the service. networks (:py:class:`list`): List of network names or IDs or :py:class:`~docker.types.NetworkAttachmentConfig` to attach the service to. Default: ``None``. resources (Resources): Resource limits and reservations. restart_policy (RestartPolicy): Restart policy for containers. secrets (list of :py:class:`~docker.types.SecretReference`): List of secrets accessible to containers for this service. stop_grace_period (int): Amount of time to wait for containers to terminate before forcefully killing them. 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`` user (str): User to run commands as. workdir (str): Working directory for commands to run. tty (boolean): Whether a pseudo-TTY should be allocated. groups (:py:class:`list`): A list of additional groups that the container process will run as. open_stdin (boolean): Open ``stdin`` read_only (boolean): Mount the container's root filesystem as read only. stop_signal (string): Set signal to stop the service's containers healthcheck (Healthcheck): Healthcheck configuration for this service. hosts (:py:class:`dict`): A set of host to IP mappings to add to the container's `hosts` file. dns_config (DNSConfig): Specification for DNS related configurations in resolver configuration file. configs (:py:class:`list`): List of :py:class:`~docker.types.ConfigReference` that will be exposed to the service. privileges (Privileges): Security options for the service's containers. cap_add (:py:class:`list`): A list of kernel capabilities to add to the default set for the container. cap_drop (:py:class:`list`): A list of kernel capabilities to drop from the default set for the container. Returns: :py:class:`Service`: The created service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. rcommandcreateNr)r!rrZcreate_servicer)rrr4r#r& service_idrrrr5s P  zServiceCollection.createcCs||jj||S)a} Get a service. Args: service_id (str): The ID of the service. insert_defaults (boolean): If true, default values will be merged into the output. Returns: :py:class:`Service`: The service. Raises: :py:class:`docker.errors.NotFound` If the service does not exist. :py:class:`docker.errors.APIError` If the server returns an error. :py:class:`docker.errors.InvalidVersion` If one of the arguments is not supported with the current API version. ) prepare_modelrrZinspect_service)rr6Zinsert_defaultsrrrrszServiceCollection.getc s"fddjjjdi|DS)a List services. Args: filters (dict): Filters to process on the nodes list. Valid filters: ``id``, ``name`` , ``label`` and ``mode``. Default: ``None``. Returns: list of :py:class:`Service`: The services. Raises: :py:class:`docker.errors.APIError` If the server returns an error. csg|]}|qSr)r7).0srrr sz*ServiceCollection.list..Nr)rrservices)rr#rrrlists zServiceCollection.listr-) r.r/r0r1r Zmodelr5rr<rrrrr3s   V r3)argsZcap_addZcap_dropr4ZconfigsZ dns_configenvgroupsZ healthcheckZhostnameZhostsrZinitZ isolationlabelsZmountsZ open_stdinZ privilegesZ read_onlyZsecretsZstop_grace_periodZ stop_signalZttyuserZworkdir)ZnetworksZ resourcesZrestart_policy)rr@r)Z update_configZ endpoint_spec)Z constraintsZ preferencesZ platformsZ maxreplicasc Csdi}t|D] }|tvr||||<qi}t|D] }|tvr)||||<qi}t|D] }|tvr>||||<q1d|vrJ|d|d<i}t|D] }|tvr^||||<qQtd i|}||d<d|vr||d|did|d<|dkrd|vr|d|d<|d d }||d <|rt||td i|}||d <t d i||d <|S)NZcontainer_labelsr@ placementZ log_driverZlog_driver_options)r ZOptionsrrr*Tcontainer_specr%r) copyCREATE_SERVICE_KWARGSpopCONTAINER_SPEC_KWARGSTASK_TEMPLATE_KWARGSPLACEMENT_KWARGSrrrr) Z func_namer#r&keyZcontainer_spec_kwargsZtask_template_kwargsrBr*rCrrrr!NsN    r!)rDZ docker.errorsrrZ docker.typesrrrrZresourcer r r r3rGrHrErIr!rrrrs