U ]3@sddlZddlmZmZddlmZmZmZmZddl m Z m Z Gddde Z Gdd d e Z d d d d ddddddddddddddddddd gZd!d"d#gZd$dd%d&d'gZd(d)d*gZd+d,ZdS)-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&|dkr i}|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|kr&|jddd}|d|d<|ddkr^|jdd}t|dd }|d |d<td |}|jjj|j|jf|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'rrrlogsUs z Service.logscCsBd|jddkrtdtd|}|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_update)N)__name__ __module__ __qualname____doc__Z id_attributepropertyrrrrrr(r,rrrrrr s   r c@s0eZdZdZeZd ddZd ddZddZdS) ServiceCollectionzServices on the Docker server.NcKs4||d<||d<td|}|jjjf|}||S)a 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. 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. Returns: :py:class:`Service`: The created service. Raises: :py:class:`docker.errors.APIError` If the server returns an error. rcommandcreate)r!rrZcreate_servicer)rrr3r#r& service_idrrrr4s J 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)rr5Zinsert_defaultsrrrrszServiceCollection.getc sfddjjjf|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)r6).0srrr sz*ServiceCollection.list..)rrservices)rr#rrrlists zServiceCollection.list)N)N) r-r.r/r0r Zmodelr4rr;rrrrr2s  P r2argsr3ZconfigsZ dns_configenvgroupsZ healthcheckZhostnameZhostsrZinitZ isolationlabelsZmountsZ open_stdinZ privilegesZ read_onlyZsecretsZstop_grace_periodZ stop_signalZttyuserZworkdirZnetworksZ resourcesZrestart_policyrr)Z update_configZ endpoint_specZ constraintsZ preferencesZ platformsc Cs^i}t|D]}|tkr||||<qi}t|D]}|tkr8||||<q8i}t|D]}|tkrb||||<qbd|kr|d|d<i}t|D]}|tkr||||<qtf|}||d<d|kr|d|did|d<|dkr*d|kr|d|d<|d d }||d <|r:t||tf|}||d <t f||d <|S) NZcontainer_labelsr? placementZ log_driverZlog_driver_options)r ZOptionsrrr*Tcontainer_specr%) copyCREATE_SERVICE_KWARGSpopCONTAINER_SPEC_KWARGSTASK_TEMPLATE_KWARGSPLACEMENT_KWARGSrrrr) Z func_namer#r&keyZcontainer_spec_kwargsZtask_template_kwargsrAr*rBrrrr!EsF       r!)rCZ docker.errorsrrZ docker.typesrrrrresourcer r r r2rFrGrDrHr!rrrrs\