o
    2.aF                     @   s~   d dl m Z  ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm	Z	 dd	lm
Z
 dd
lmZ G dd dZdS )    )datetime   )errors)utils)DEFAULT_DATA_CHUNK_SIZE)CancellableStream)ContainerConfig)EndpointConfig)
HostConfigNetworkingConfigc                   @   sV  e Zd Zed		dHddZeddIddZed		dJd	d
Z			dKddZ									dLddZ	dd Z
dMddZdd Zdd Zdd Zeddd ZedefddZededfddZedd d! ZeddMd"d#Zed			dNd%d&Zedd'd( Zedd)d* Zedd+d, Zed-dMd.d/ZeddOd0d1Zedd2d3 Zedd4d5 ZeddPd7d8Zedd9d: ZeddQd;d<Z eddMd=d>Z!eddMd?d@Z"eddAdB Z#edCed				dRdDdEZ$eddSdFdGZ%dS )TContainerApiMixin	containerTFc                 C   s   |rdpd|r	dp
d|rdpd|rdpdd}ddd}|  d|}	| j|	||dd	}
| j|
|| ||d
}|r>t||
S |S )aI  
        Attach to a container.

        The ``.logs()`` function is a wrapper around this method, which you can
        use instead if you want to fetch/stream container output without first
        retrieving the entire backlog.

        Args:
            container (str): The container to attach to.
            stdout (bool): Include stdout.
            stderr (bool): Include stderr.
            stream (bool): Return container output progressively as an iterator
                of strings, rather than a single string.
            logs (bool): Include the container's previous output.
            demux (bool): Keep stdout and stderr separate.

        Returns:
            By default, the container's output as a single string (two if
            ``demux=True``: one for stdout and one for stderr).

            If ``stream=True``, an iterator of output strings. If
            ``demux=True``, two iterators are returned: one for stdout and one
            for stderr.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
           r   )logsstdoutstderrstreamUpgradetcpZ
Connectionr   /containers/{0}/attachT)headersparamsr   )demux)_url_postZ_read_from_socketZ_check_is_ttyr   )selfr   r   r   r   r   r   r   r   uZresponseoutput r    6/usr/lib/python3/dist-packages/docker/api/container.pyattach   s    
 



zContainerApiMixin.attachNc              	   C   sz   |du r
dddd}d|vrd| j v r| j d |d< |r"| ||S ddd}| d|}| | j|d| |d	|d
S )a&  
        Like ``attach``, but returns the underlying socket-like object for the
        HTTP request.

        Args:
            container (str): The container to attach to.
            params (dict): Dictionary of request parameters (e.g. ``stdout``,
                ``stderr``, ``stream``).
                For ``detachKeys``, ~/.docker/config.json is used by default.
            ws (bool): Use websockets instead of raw HTTP.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        Nr   )r   r   r   Z
detachKeysr   r   r   r   Tr   r   r   )Z_general_configsZ_attach_websocketr   Z_get_raw_response_socketZpostZ_attach_params)r   r   r   Zwsr   r   r    r    r!   attach_socketD   s*   zContainerApiMixin.attach_socketc           
      C   s6   ||||||d}|  d}	| j| j|	||dddS )a  
        Commit a container to an image. Similar to the ``docker commit``
        command.

        Args:
            container (str): The image hash of the container
            repository (str): The repository to push the image to
            tag (str): The tag to push
            message (str): A commit message
            author (str): The name of the author
            changes (str): Dockerfile instructions to apply while committing
            conf (dict): The configuration for the container. See the
                `Engine API documentation
                <https://docs.docker.com/reference/api/docker_remote_api/>`_
                for full details.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        )r   ZrepotagZcommentauthorchangesz/commitdatar   Tjson)r   _result
_post_json)
r   r   Z
repositoryr%   messager&   r'   confr   r   r    r    r!   commitq   s   
zContainerApiMixin.commitc
                 C   s   |rdn||r	dnd|rdnd|rdnd||d}
|	r"t |	|
d< | d}| | j||
dd}|r;dd	 |D S |rL|D ]}|d
 dd |d
< q?|S )a6  
        List containers. Similar to the ``docker ps`` command.

        Args:
            quiet (bool): Only display numeric Ids
            all (bool): Show all containers. Only running containers are shown
                by default
            trunc (bool): Truncate output
            latest (bool): Show only the latest created container, include
                non-running ones.
            since (str): Show only containers created since Id or Name, include
                non-running ones
            before (str): Show only container created before Id or Name,
                include non-running ones
            limit (int): Show `limit` last created containers, include
                non-running ones
            size (bool): Display sizes
            filters (dict): Filters to be processed on the image list.
                Available filters:

                - `exited` (int): Only containers with specified exit code
                - `status` (str): One of ``restarting``, ``running``,
                    ``paused``, ``exited``
                - `label` (str|list): format either ``"key"``, ``"key=value"``
                    or a list of such.
                - `id` (str): The id of the container.
                - `name` (str): The name of the container.
                - `ancestor` (str): Filter by container ancestor. Format of
                    ``<image-name>[:tag]``, ``<image-id>``, or
                    ``<image@digest>``.
                - `before` (str): Only containers created before a particular
                    container. Give the container name or id.
                - `since` (str): Only containers created after a particular
                    container. Give container name or id.

                A comprehensive list can be found in the documentation for
                `docker ps
                <https://docs.docker.com/engine/reference/commandline/ps>`_.

        Returns:
            A list of dicts, one per container

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        r   r   )limitallsizeZ	trunc_cmdsincebeforefiltersz/containers/jsonr   Tc                 S   s   g | ]}d |d  iqS )Idr    ).0xr    r    r!   
<listcomp>   s    z0ContainerApiMixin.containers.<locals>.<listcomp>r9   N   )r   convert_filtersr   r,   _get)r   quietr3   ZtruncZlatestr5   r6   r2   r4   r7   r   r   resr;   r    r    r!   
containers   s"   
2



zContainerApiMixin.containersc                 C   sz   t |
tr|
g}
t |	trtj|	}	|r| j|	pd}	| |||||||||	|
||||||||||||}| ||S )a  
        Creates a container. Parameters are similar to those for the ``docker
        run`` command except it doesn't support the attach options (``-a``).

        The arguments that are passed directly to this function are
        host-independent configuration options. Host-specific configuration
        is passed with the `host_config` argument. You'll normally want to
        use this method in combination with the :py:meth:`create_host_config`
        method to generate ``host_config``.

        **Port bindings**

        Port binding is done in two parts: first, provide a list of ports to
        open inside the container with the ``ports`` parameter, then declare
        bindings with the ``host_config`` parameter. For example:

        .. code-block:: python

            container_id = client.api.create_container(
                'busybox', 'ls', ports=[1111, 2222],
                host_config=client.api.create_host_config(port_bindings={
                    1111: 4567,
                    2222: None
                })
            )


        You can limit the host address on which the port will be exposed like
        such:

        .. code-block:: python

            client.api.create_host_config(port_bindings={1111: ('127.0.0.1', 4567)})

        Or without host port assignment:

        .. code-block:: python

            client.api.create_host_config(port_bindings={1111: ('127.0.0.1',)})

        If you wish to use UDP instead of TCP (default), you need to declare
        ports as such in both the config and host config:

        .. code-block:: python

            container_id = client.api.create_container(
                'busybox', 'ls', ports=[(1111, 'udp'), 2222],
                host_config=client.api.create_host_config(port_bindings={
                    '1111/udp': 4567, 2222: None
                })
            )

        To bind multiple host ports to a single container port, use the
        following syntax:

        .. code-block:: python

            client.api.create_host_config(port_bindings={
                1111: [1234, 4567]
            })

        You can also bind multiple IPs to a single container port:

        .. code-block:: python

            client.api.create_host_config(port_bindings={
                1111: [
                    ('192.168.0.100', 1234),
                    ('192.168.0.101', 1234)
                ]
            })

        **Using volumes**

        Volume declaration is done in two parts. Provide a list of
        paths to use as mountpoints inside the container with the
        ``volumes`` parameter, and declare mappings from paths on the host
        in the ``host_config`` section.

        .. code-block:: python

            container_id = client.api.create_container(
                'busybox', 'ls', volumes=['/mnt/vol1', '/mnt/vol2'],
                host_config=client.api.create_host_config(binds={
                    '/home/user1/': {
                        'bind': '/mnt/vol2',
                        'mode': 'rw',
                    },
                    '/var/www': {
                        'bind': '/mnt/vol1',
                        'mode': 'ro',
                    }
                })
            )

        You can alternatively specify binds as a list. This code is equivalent
        to the example above:

        .. code-block:: python

            container_id = client.api.create_container(
                'busybox', 'ls', volumes=['/mnt/vol1', '/mnt/vol2'],
                host_config=client.api.create_host_config(binds=[
                    '/home/user1/:/mnt/vol2',
                    '/var/www:/mnt/vol1:ro',
                ])
            )

        **Networking**

        You can specify networks to connect the container to by using the
        ``networking_config`` parameter. At the time of creation, you can
        only connect a container to a single networking, but you
        can create more connections by using
        :py:meth:`~connect_container_to_network`.

        For example:

        .. code-block:: python

            networking_config = client.api.create_networking_config({
                'network1': client.api.create_endpoint_config(
                    ipv4_address='172.28.0.124',
                    aliases=['foo', 'bar'],
                    links=['container2']
                )
            })

            ctnr = client.api.create_container(
                img, command, networking_config=networking_config
            )

        Args:
            image (str): The image to run
            command (str or list): The command to be run in the container
            hostname (str): Optional hostname for the container
            user (str or int): Username or UID
            detach (bool): Detached mode: run container in the background and
                return container ID
            stdin_open (bool): Keep STDIN open even if not attached
            tty (bool): Allocate a pseudo-TTY
            ports (list of ints): A list of port numbers
            environment (dict or list): A dictionary or a list of strings in
                the following format ``["PASSWORD=xxx"]`` or
                ``{"PASSWORD": "xxx"}``.
            volumes (str or list): List of paths inside the container to use
                as volumes.
            network_disabled (bool): Disable networking
            name (str): A name for the container
            entrypoint (str or list): An entrypoint
            working_dir (str): Path to the working directory
            domainname (str): The domain name to use for the container
            host_config (dict): A dictionary created with
                :py:meth:`create_host_config`.
            mac_address (str): The Mac Address to assign the container
            labels (dict or list): A dictionary of name-value labels (e.g.
                ``{"label1": "value1", "label2": "value2"}``) or a list of
                names of labels to set with empty values (e.g.
                ``["label1", "label2"]``)
            stop_signal (str): The stop signal to use to stop the container
                (e.g. ``SIGINT``).
            stop_timeout (int): Timeout to stop the container, in seconds.
                Default: 10
            networking_config (dict): A networking configuration generated
                by :py:meth:`create_networking_config`.
            runtime (str): Runtime to use with this container.
            healthcheck (dict): Specify a test to perform to check that the
                container is healthy.
            use_config_proxy (bool): If ``True``, and if the docker client
                configuration file (``~/.docker/config.json`` by default)
                contains a proxy configuration, the corresponding environment
                variables will be set in the container being created.

        Returns:
            A dictionary with an image 'Id' key and a 'Warnings' key.

        Raises:
            :py:class:`docker.errors.ImageNotFound`
                If the specified image does not exist.
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        N)	
isinstancestrdictr   Zformat_environmentZ_proxy_configsZinject_proxy_environmentcreate_container_configcreate_container_from_config)r   ZimageZcommandZhostnameuserdetachZ
stdin_openZttyZportsZenvironmentZvolumesZnetwork_disablednameZ
entrypointZworking_dirZ
domainnameZhost_configZmac_addresslabelsZstop_signalZnetworking_configZhealthcheckZstop_timeoutZruntimeZuse_config_proxyconfigr    r    r!   create_container   s(    
@
z"ContainerApiMixin.create_containerc                 O      t | jg|R i |S N)r   _versionr   argskwargsr    r    r!   rF     s   z)ContainerApiMixin.create_container_configc                 C   s.   |  d}d|i}| j|||d}| |dS )Nz/containers/createrJ   r(   T)r   r-   r,   )r   rL   rJ   r   r   rA   r    r    r!   rG     s
   
z.ContainerApiMixin.create_container_from_configc                 O   s0   |si }d|v rt d| j|d< t|i |S )aU  
        Create a dictionary for the ``host_config`` argument to
        :py:meth:`create_container`.

        Args:
            auto_remove (bool): enable auto-removal of the container on daemon
                side when the container's process exits.
            binds (dict): Volumes to bind. See :py:meth:`create_container`
                    for more information.
            blkio_weight_device: Block IO weight (relative device weight) in
                the form of: ``[{"Path": "device_path", "Weight": weight}]``.
            blkio_weight: Block IO weight (relative weight), accepts a weight
                value between 10 and 1000.
            cap_add (list of str): Add kernel capabilities. For example,
                ``["SYS_ADMIN", "MKNOD"]``.
            cap_drop (list of str): Drop kernel capabilities.
            cpu_period (int): The length of a CPU period in microseconds.
            cpu_quota (int): Microseconds of CPU time that the container can
                get in a CPU period.
            cpu_shares (int): CPU shares (relative weight).
            cpuset_cpus (str): CPUs in which to allow execution (``0-3``,
                ``0,1``).
            cpuset_mems (str): Memory nodes (MEMs) in which to allow execution
                (``0-3``, ``0,1``). Only effective on NUMA systems.
            device_cgroup_rules (:py:class:`list`): A list of cgroup rules to
                apply to the container.
            device_read_bps: Limit read rate (bytes per second) from a device
                in the form of: `[{"Path": "device_path", "Rate": rate}]`
            device_read_iops: Limit read rate (IO per second) from a device.
            device_write_bps: Limit write rate (bytes per second) from a
                device.
            device_write_iops: Limit write rate (IO per second) from a device.
            devices (:py:class:`list`): Expose host devices to the container,
                as a list of strings in the form
                ``<path_on_host>:<path_in_container>:<cgroup_permissions>``.

                For example, ``/dev/sda:/dev/xvda:rwm`` allows the container
                to have read-write access to the host's ``/dev/sda`` via a
                node named ``/dev/xvda`` inside the container.
            device_requests (:py:class:`list`): Expose host resources such as
                GPUs to the container, as a list of
                :py:class:`docker.types.DeviceRequest` instances.
            dns (:py:class:`list`): Set custom DNS servers.
            dns_opt (:py:class:`list`): Additional options to be added to the
                container's ``resolv.conf`` file
            dns_search (:py:class:`list`): DNS search domains.
            extra_hosts (dict): Additional hostnames to resolve inside the
                container, as a mapping of hostname to IP address.
            group_add (:py:class:`list`): List of additional group names and/or
                IDs that the container process will run as.
            init (bool): Run an init inside the container that forwards
                signals and reaps processes
            ipc_mode (str): Set the IPC mode for the container.
            isolation (str): Isolation technology to use. Default: ``None``.
            links (dict): Mapping of links using the
                ``{'container': 'alias'}`` format. The alias is optional.
                Containers declared in this dict will be linked to the new
                container using the provided alias. Default: ``None``.
            log_config (LogConfig): Logging configuration
            lxc_conf (dict): LXC config.
            mem_limit (float or str): Memory limit. Accepts float values
                (which represent the memory limit of the created container in
                bytes) or a string with a units identification char
                (``100000b``, ``1000k``, ``128m``, ``1g``). If a string is
                specified without a units character, bytes are assumed as an
            mem_reservation (float or str): Memory soft limit.
            mem_swappiness (int): Tune a container's memory swappiness
                behavior. Accepts number between 0 and 100.
            memswap_limit (str or int): Maximum amount of memory + swap a
                container is allowed to consume.
            mounts (:py:class:`list`): Specification for mounts to be added to
                the container. More powerful alternative to ``binds``. Each
                item in the list is expected to be a
                :py:class:`docker.types.Mount` object.
            network_mode (str): One of:

                - ``bridge`` Create a new network stack for the container on
                  the bridge network.
                - ``none`` No networking for this container.
                - ``container:<name|id>`` Reuse another container's network
                  stack.
                - ``host`` Use the host network stack.
                  This mode is incompatible with ``port_bindings``.

            oom_kill_disable (bool): Whether to disable OOM killer.
            oom_score_adj (int): An integer value containing the score given
                to the container in order to tune OOM killer preferences.
            pid_mode (str): If set to ``host``, use the host PID namespace
                inside the container.
            pids_limit (int): Tune a container's pids limit. Set ``-1`` for
                unlimited.
            port_bindings (dict): See :py:meth:`create_container`
                for more information.
                Imcompatible with ``host`` in ``network_mode``.
            privileged (bool): Give extended privileges to this container.
            publish_all_ports (bool): Publish all ports to the host.
            read_only (bool): Mount the container's root filesystem as read
                only.
            restart_policy (dict): Restart the container when it exits.
                Configured as a dictionary with keys:

                - ``Name`` One of ``on-failure``, or ``always``.
                - ``MaximumRetryCount`` Number of times to restart the
                  container on failure.
            security_opt (:py:class:`list`): A list of string values to
                customize labels for MLS systems, such as SELinux.
            shm_size (str or int): Size of /dev/shm (e.g. ``1G``).
            storage_opt (dict): Storage driver options per container as a
                key-value mapping.
            sysctls (dict): Kernel parameters to set in the container.
            tmpfs (dict): Temporary filesystems to mount, as a dictionary
                mapping a path inside the container to options for that path.

                For example:

                .. code-block:: python

                    {
                        '/mnt/vol2': '',
                        '/mnt/vol1': 'size=3G,uid=1000'
                    }

            ulimits (:py:class:`list`): Ulimits to set inside the container,
                as a list of :py:class:`docker.types.Ulimit` instances.
            userns_mode (str): Sets the user namespace mode for the container
                when user namespace remapping option is enabled. Supported
                values are: ``host``
            uts_mode (str): Sets the UTS namespace mode for the container.
                Supported values are: ``host``
            volumes_from (:py:class:`list`): List of container names or IDs to
                get volumes from.
            runtime (str): Runtime to use with this container.


        Returns:
            (dict) A dictionary which can be passed to the ``host_config``
            argument to :py:meth:`create_container`.

        Example:

            >>> client.api.create_host_config(privileged=True, cap_drop=['MKNOD'],
                                       volumes_from=['nostalgic_newton'])
            {'CapDrop': ['MKNOD'], 'LxcConf': None, 'Privileged': True,
             'VolumesFrom': ['nostalgic_newton'], 'PublishAllPorts': False}

versionzAcreate_host_config() got an unexpected keyword argument 'version')	TypeErrorrP   r
   rQ   r    r    r!   create_host_config  s    
z$ContainerApiMixin.create_host_configc                 O   s   t |i |S )a  
        Create a networking config dictionary to be used as the
        ``networking_config`` parameter in :py:meth:`create_container`.

        Args:
            endpoints_config (dict): A dictionary mapping network names to
                endpoint configurations generated by
                :py:meth:`create_endpoint_config`.

        Returns:
            (dict) A networking config.

        Example:

            >>> client.api.create_network('network1')
            >>> networking_config = client.api.create_networking_config({
                'network1': client.api.create_endpoint_config()
            })
            >>> container = client.api.create_container(
                img, command, networking_config=networking_config
            )

        r   rQ   r    r    r!   create_networking_configV  s   z*ContainerApiMixin.create_networking_configc                 O   rN   )a  
        Create an endpoint config dictionary to be used with
        :py:meth:`create_networking_config`.

        Args:
            aliases (:py:class:`list`): A list of aliases for this endpoint.
                Names in that list can be used within the network to reach the
                container. Defaults to ``None``.
            links (dict): Mapping of links for this endpoint using the
                ``{'container': 'alias'}`` format. The alias is optional.
                Containers declared in this dict will be linked to this
                container using the provided alias. Defaults to ``None``.
            ipv4_address (str): The IP address of this container on the
                network, using the IPv4 protocol. Defaults to ``None``.
            ipv6_address (str): The IP address of this container on the
                network, using the IPv6 protocol. Defaults to ``None``.
            link_local_ips (:py:class:`list`): A list of link-local (IPv4/IPv6)
                addresses.
            driver_opt (dict): A dictionary of options to provide to the
                network driver. Defaults to ``None``.

        Returns:
            (dict) An endpoint config.

        Example:

            >>> endpoint_config = client.api.create_endpoint_config(
                aliases=['web', 'app'],
                links={'app_db': 'db', 'another': None},
                ipv4_address='132.65.0.123'
            )

        )r	   rP   rQ   r    r    r!   create_endpoint_configp  s   "z(ContainerApiMixin.create_endpoint_configc                 C      |  | | d|dS )a  
        Inspect changes on a container's filesystem.

        Args:
            container (str): The container to diff

        Returns:
            (str)

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        z/containers/{0}/changesTr,   r?   r   r   r   r    r    r!   diff  s   zContainerApiMixin.diffc                 C   s$   | j | d|dd}| ||dS )a  
        Export the contents of a filesystem as a tar archive.

        Args:
            container (str): The container to export
            chunk_size (int): The number of bytes returned by each iteration
                of the generator. If ``None``, data will be streamed as it is
                received. Default: 2 MB

        Returns:
            (generator): The archived filesystem data stream

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        z/containers/{0}/exportTr   F)r?   r   _stream_raw_result)r   r   
chunk_sizerA   r    r    r!   export  s   zContainerApiMixin.exportc           
      C   sr   d|i}|r
ddinddi}|  d|}| j||d|d}| | |jd}	| ||d	|	r6t|	fS d
fS )a  
        Retrieve a file or folder from a container in the form of a tar
        archive.

        Args:
            container (str): The container where the file is located
            path (str): Path to the file or folder to retrieve
            chunk_size (int): The number of bytes returned by each iteration
                of the generator. If ``None``, data will be streamed as it is
                received. Default: 2 MB
            encode_stream (bool): Determines if data should be encoded
                (gzip-compressed) during transmission. Default: False

        Returns:
            (tuple): First element is a raw tar data stream. Second element is
            a dict containing ``stat`` information on the specified ``path``.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.

        Example:

            >>> c = docker.APIClient()
            >>> f = open('./sh_bin.tar', 'wb')
            >>> bits, stat = c.api.get_archive(container, '/bin/sh')
            >>> print(stat)
            {'name': 'sh', 'size': 1075464, 'mode': 493,
             'mtime': '2018-10-01T15:37:48-07:00', 'linkTarget': ''}
            >>> for chunk in bits:
            ...    f.write(chunk)
            >>> f.close()
        pathzAccept-Encodingzgzip, deflateidentity/containers/{0}/archiveTr#   zx-docker-container-path-statFN)r   r?   _raise_for_statusr   getr^   r   Zdecode_json_header)
r   r   ra   r_   Zencode_streamr   r   urlrA   Zencoded_statr    r    r!   get_archive  s$   %
zContainerApiMixin.get_archivec                 C   rY   )a|  
        Identical to the `docker inspect` command, but only for containers.

        Args:
            container (str): The container to inspect

        Returns:
            (dict): Similar to the output of `docker inspect`, but as a
            single dict

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        /containers/{0}/jsonTrZ   r[   r    r    r!   inspect_container  s   z#ContainerApiMixin.inspect_containerc                 C   sN   |  d|}i }|durt|tst|}||d< | j||d}| | dS )aB  
        Kill a container or send a signal to a container.

        Args:
            container (str): The container to kill
            signal (str or int): The signal to send. Defaults to ``SIGKILL``

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        z/containers/{0}/killNsignalr8   )r   rC   rD   intr   rd   )r   r   rj   rf   r   rA   r    r    r!   kill  s   
zContainerApiMixin.killr3   c
                 C   sX  |du r|}|r
dpd|rdpd|rdpd|rdpdd}
|dkr,t |tr*|dk r,d}||
d< |durYt |trAt||
d< nt |trO|dkrO||
d< n
tdt||	durt	| j
d	ritd
t |	trvt|	|
d< nt |	tr|	dkr|	|
d< n
tdt|	| d|}| j||
|d}| |||}|rt||S |S )a  
        Get logs from a container. Similar to the ``docker logs`` command.

        The ``stream`` parameter makes the ``logs`` function return a blocking
        generator you can iterate over to retrieve log output as it happens.

        Args:
            container (str): The container to get logs from
            stdout (bool): Get ``STDOUT``. Default ``True``
            stderr (bool): Get ``STDERR``. Default ``True``
            stream (bool): Stream the response. Default ``False``
            timestamps (bool): Show timestamps. Default ``False``
            tail (str or int): Output specified number of lines at the end of
                logs. Either an integer of number of lines or the string
                ``all``. Default ``all``
            since (datetime or int): Show logs since a given datetime or
                integer epoch (in seconds)
            follow (bool): Follow log output. Default ``False``
            until (datetime or int): Show logs that occurred before the given
                datetime or integer epoch (in seconds)

        Returns:
            (generator or str)

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        Nr   r   )r   r   
timestampsfollowr3   tailr5   z6since value should be datetime or positive int, not {}z1.35z-until is not supported for API version < 1.35untilz6until value should be datetime or positive int, not {}z/containers/{0}/logs)r   r   )rC   rk   r   r   Zdatetime_to_timestampr   InvalidArgumentformattype
version_ltrP   InvalidVersionr   r?   Z_get_resultr   )r   r   r   r   r   rm   ro   r5   rn   rp   r   rf   rA   r   r    r    r!   r     sL    










zContainerApiMixin.logsc                 C   $   |  d|}| |}| | dS )z
        Pauses all processes within a container.

        Args:
            container (str): The container to pause

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        z/containers/{0}/pauseNr   r   rd   r   r   rf   rA   r    r    r!   pausel  s   
zContainerApiMixin.pausec                 C   s   |  | d|}| | | }t|}d}|di d}|du r'dS d|v r0||S dD ]}||d | }|rB |S q2|S )a#  
        Lookup the public-facing port that is NAT-ed to ``private_port``.
        Identical to the ``docker port`` command.

        Args:
            container (str): The container to look up
            private_port (int): The private port to inspect

        Returns:
            (list of dict): The mapping for the host ports

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.

        Example:
            .. code-block:: bash

                $ docker run -d -p 80:80 ubuntu:14.04 /bin/sleep 30
                7174d6347063a83f412fad6124c99cffd25ffe1a0807eb4b7f9cec76ac8cb43b

            .. code-block:: python

                >>> client.api.port('7174d6347063', 80)
                [{'HostIp': '0.0.0.0', 'HostPort': '80'}]
        rh   NZNetworkSettingsZPorts/)r   ZudpZsctp)r?   r   rd   r+   rD   re   )r   r   Zprivate_portrA   Zjson_Zh_portsZport_settingsZprotocolr    r    r!   port|  s"   

zContainerApiMixin.portc                 C   s8   d|i}|  d|}| j|||d}| | |jdkS )a  
        Insert a file or folder in an existing container using a tar archive as
        source.

        Args:
            container (str): The container where the file(s) will be extracted
            path (str): Path inside the container where the file(s) will be
                extracted. Must exist.
            data (bytes): tar data to be extracted

        Returns:
            (bool): True if the call succeeds.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        ra   rc   )r   r)      )r   Z_putrd   Zstatus_code)r   r   ra   r)   r   rf   rA   r    r    r!   put_archive  s
   

zContainerApiMixin.put_archivez1.25c                 C   s6   i }|rt ||d< | d}| | j||ddS )a  
        Delete stopped containers

        Args:
            filters (dict): Filters to process on the prune list.

        Returns:
            (dict): A dict containing a list of deleted container IDs and
                the amount of disk space reclaimed in bytes.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        r7   z/containers/pruner8   T)r   r>   r   r,   r   )r   r7   r   rf   r    r    r!   prune_containers  s
   
z"ContainerApiMixin.prune_containersc                 C   s0   |||d}| j | d||d}| | dS )a  
        Remove a container. Similar to the ``docker rm`` command.

        Args:
            container (str): The container to remove
            v (bool): Remove the volumes associated with the container
            link (bool): Remove the specified link and not the underlying
                container
            force (bool): Force the removal of a running container (uses
                ``SIGKILL``)

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        )vlinkforcez/containers/{0}r8   N)Z_deleter   rd   )r   r   r   r   r   r   rA   r    r    r!   remove_container  s
   z"ContainerApiMixin.remove_containerc                 C   s0   |  d|}d|i}| j||d}| | dS )a<  
        Rename a container. Similar to the ``docker rename`` command.

        Args:
            container (str): ID of the container to rename
            name (str): New name for the container

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        z/containers/{0}/renamerJ   r8   Nrw   )r   r   rJ   rf   r   rA   r    r    r!   rename  s   zContainerApiMixin.renamec                 C   s2   ||d}|  d|}| j||d}| | dS )aC  
        Resize the tty session.

        Args:
            container (str or dict): The container to resize
            height (int): Height of tty session
            width (int): Width of tty session

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        )hwz/containers/{0}/resizer8   Nrw   )r   r   Zheightwidthr   rf   rA   r    r    r!   resize  s   
zContainerApiMixin.resize
   c                 C   sH   d|i}|  d|}| j}|dur||7 }| j|||d}| | dS )a  
        Restart a container. Similar to the ``docker restart`` command.

        Args:
            container (str or dict): The container to restart. If a dict, the
                ``Id`` key is used.
            timeout (int): Number of seconds to try to stop for before killing
                the container. Once killed it will then be restarted. Default
                is 10 seconds.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        tz/containers/{0}/restartNr   timeoutr   r   r   rd   r   r   r   r   rf   Zconn_timeoutrA   r    r    r!   restart  s   zContainerApiMixin.restartc                 O   s6   |s|r	t d| d|}| |}| | dS )a  
        Start a container. Similar to the ``docker start`` command, but
        doesn't support attach options.

        **Deprecation warning:** Passing configuration options in ``start`` is
        no longer supported. Users are expected to provide host config options
        in the ``host_config`` parameter of
        :py:meth:`~ContainerApiMixin.create_container`.


        Args:
            container (str): The container to start

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
            :py:class:`docker.errors.DeprecatedMethod`
                If any argument besides ``container`` are provided.

        Example:

            >>> container = client.api.create_container(
            ...     image='busybox:latest',
            ...     command='/bin/sleep 30')
            >>> client.api.start(container=container.get('Id'))
        z|Providing configuration in the start() method is no longer supported. Use the host_config param in create_container instead.z/containers/{0}/startN)r   ZDeprecatedMethodr   r   rd   )r   r   rR   rS   rf   rA   r    r    r!   start1  s   
zContainerApiMixin.startc                 C   sR   |  d|}|r| j| j|dd|dS |rtd| j| j|ddiddd	S )
ao  
        Stream statistics for a specific container. Similar to the
        ``docker stats`` command.

        Args:
            container (str): The container to stream statistics from
            decode (bool): If set to true, stream will be decoded into dicts
                on the fly. Only applicable if ``stream`` is True.
                False by default.
            stream (bool): If set to false, only the current stats will be
                returned instead of a stream. True by default.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.

        z/containers/{0}/statsTr]   )decodez8decode is only available in conjunction with stream=Truer   Fr8   r*   )r   Z_stream_helperr?   r   rq   r,   )r   r   r   r   rf   r    r    r!   statsW  s   zContainerApiMixin.statsc                 C   sZ   |du r	i }d}nd|i}|  d|}| j}|dur||7 }| j|||d}| | dS )a  
        Stops a container. Similar to the ``docker stop`` command.

        Args:
            container (str): The container to stop
            timeout (int): Timeout in seconds to wait for the container to
                stop before sending a ``SIGKILL``. If None, then the
                StopTimeout value of the container will be used.
                Default: None

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        Nr   r   z/containers/{0}/stopr   r   r   r    r    r!   stopv  s   zContainerApiMixin.stopc                 C   s6   |  d|}i }|dur||d< | | j||ddS )a|  
        Display the running processes of a container.

        Args:
            container (str): The container to inspect
            ps_args (str): An optional arguments passed to ps (e.g. ``aux``)

        Returns:
            (str): The output of the top

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        z/containers/{0}/topNps_argsr8   T)r   r,   r?   )r   r   r   r   r   r    r    r!   top  s
   zContainerApiMixin.topc                 C   rv   )z
        Unpause all processes within a container.

        Args:
            container (str): The container to unpause
        z/containers/{0}/unpauseNrw   rx   r    r    r!   unpause  s   
zContainerApiMixin.unpausez1.22c                 C   s   |  d|}i }|r||d< |r||d< |r||d< |r ||d< |r&||d< |r,||d< |r5t||d< |	r>t|	|d	< |
rGt|
|d
< |rPt||d< |rbt| jdr^td||d< | j||d}| |dS )aC  
        Update resource configs of one or more containers.

        Args:
            container (str): The container to inspect
            blkio_weight (int): Block IO (relative weight), between 10 and 1000
            cpu_period (int): Limit CPU CFS (Completely Fair Scheduler) period
            cpu_quota (int): Limit CPU CFS (Completely Fair Scheduler) quota
            cpu_shares (int): CPU shares (relative weight)
            cpuset_cpus (str): CPUs in which to allow execution
            cpuset_mems (str): MEMs in which to allow execution
            mem_limit (float or str): Memory limit
            mem_reservation (float or str): Memory soft limit
            memswap_limit (int or str): Total memory (memory + swap), -1 to
                disable swap
            kernel_memory (int or str): Kernel memory limit
            restart_policy (dict): Restart policy dictionary

        Returns:
            (dict): Dictionary containing a ``Warnings`` key.

        Raises:
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        z/containers/{0}/updateZBlkioWeightZ	CpuPeriodZ	CpuSharesZCpuQuotaZ
CpusetCpusZ
CpusetMemsZMemoryZMemoryReservationZ
MemorySwapZKernelMemoryz1.23z=restart policy update is not supported for API version < 1.23ZRestartPolicy)r)   T)	r   r   Zparse_bytesrt   rP   r   ru   r-   r,   )r   r   Zblkio_weightZ
cpu_periodZ	cpu_quotaZ
cpu_sharesZcpuset_cpusZcpuset_memsZ	mem_limitZmem_reservationZmemswap_limitZkernel_memoryZrestart_policyrf   r)   rA   r    r    r!   update_container  s<   !z"ContainerApiMixin.update_containerc                 C   sT   |  d|}i }|durt| jdrtd||d< | j|||d}| |dS )a[  
        Block until a container stops, then return its exit code. Similar to
        the ``docker wait`` command.

        Args:
            container (str or dict): The container to wait on. If a dict, the
                ``Id`` key is used.
            timeout (int): Request timeout
            condition (str): Wait until a container state reaches the given
                condition, either ``not-running`` (default), ``next-exit``,
                or ``removed``

        Returns:
            (dict): The API's response as a Python dictionary, including
                the container's exit code under the ``StatusCode`` attribute.

        Raises:
            :py:class:`requests.exceptions.ReadTimeout`
                If the timeout is exceeded.
            :py:class:`docker.errors.APIError`
                If the server returns an error.
        z/containers/{0}/waitNz1.30z6wait condition is not supported for API version < 1.30	condition)r   r   T)r   r   rt   rP   r   ru   r   r,   )r   r   r   r   rf   r   rA   r    r    r!   wait  s   zContainerApiMixin.wait)TTFFF)NF)NNNNNN)	FFFFNNr1   FN)NNNFFFNNNFNNNNNNNNNNNNTrO   )TTFFr3   NNN)FFF)r   )NT)NNNNNNNNNNN)NN)&__name__
__module____qualname__r   Zcheck_resourcer"   r$   r0   rB   rM   rF   rG   rV   rW   rX   r\   r   r`   rg   ri   rl   r   ry   r{   r}   Zminimum_versionr~   r   r   r   r   r   r   r   r   r   r   r   r    r    r    r!   r      s    5,#
E
 U
 $
4
M

1



%
@r   N)r    r   r   Z	constantsr   typesr   r   r	   r
   r   r   r    r    r    r!   <module>   s    