o 2.ax@s:ddlZddlmZddlmZmZmZGdddZdS)N)datetime)authtypesutilsc@sPeZdZedddZdddZddZ  dd d Zd d Z dddZ dS)DaemonApiMixinz1.25cCs|d}|||dS)a( Get data usage information. Returns: (dict): A dictionary representing different resource categories and their respective data usage. Raises: :py:class:`docker.errors.APIError` If the server returns an error. z /system/dfT_url_result_get)selfurlr3/usr/lib/python3/dist-packages/docker/api/daemon.pydfs zDaemonApiMixin.dfNc Csxt|tr t|}t|trt|}|rt|}|||d}|d}|j||ddd}|j||d}t ||S)ar Get real-time events from the server. Similar to the ``docker events`` command. Args: since (UTC datetime or int): Get events from this point until (UTC datetime or int): Get events until this point filters (dict): Filter the events by event time, container or image decode (bool): If set to true, stream will be decoded into dicts on the fly. False by default. Returns: A :py:class:`docker.types.daemon.CancellableStream` generator Raises: :py:class:`docker.errors.APIError` If the server returns an error. Example: >>> for event in client.events(decode=True) ... print(event) {u'from': u'image/with:tag', u'id': u'container-id', u'status': u'start', u'time': 1423339459} ... or >>> events = client.events() >>> for event in events: ... print(event) >>> # and cancel from another thread >>> events.close() )sinceuntilfiltersz/eventsTN)paramsstreamZtimeout)decode) isinstancerrZdatetime_to_timestampZconvert_filtersr r Z_stream_helperrZCancellableStream) r rrrrrr responserrrreventss &      zDaemonApiMixin.eventscCs|||ddS)a  Display system-wide information. Identical to the ``docker info`` command. Returns: (dict): The info as a dict Raises: :py:class:`docker.errors.APIError` If the server returns an error. z/infoTr r r r rrrinfoSs zDaemonApiMixin.infoFc Cs|rtj|rtj||jd|_n|jr|jjr!tj|jd|_|j|}|r5| dd|kr5|s5|S||||d}|j | d|d} | j dkrU|j |pRtj||j| dd S) a^ Authenticate with a registry. Similar to the ``docker login`` command. Args: username (str): The registry username password (str): The plaintext password email (str): The email for the registry account registry (str): URL to the registry. E.g. ``https://index.docker.io/v1/`` reauth (bool): Whether or not to refresh existing authentication on the Docker server. dockercfg_path (str): Use a custom path for the Docker config file (default ``$HOME/.docker/config.json`` if present, otherwise ``$HOME/.dockercfg``) Returns: (dict): The response from the login request Raises: :py:class:`docker.errors.APIError` If the server returns an error. ) credstore_envusernameN)rpasswordemailZ serveraddressz/auth)dataTZjson)ospathexistsrZ load_configrZ _auth_configsZis_emptyZresolve_authconfiggetZ _post_jsonr Z status_codeZadd_authZ INDEX_NAMEr ) r rrr registryZreauthZdockercfg_pathZauthcfgZreq_datarrrrloginas,   zDaemonApiMixin.logincCs|||ddkS)a! Checks the server is responsive. An exception will be raised if it isn't responding. Returns: (bool) The response from the server. Raises: :py:class:`docker.errors.APIError` If the server returns an error. z/_pingZOKrrrrrpings zDaemonApiMixin.pingTcCs"|jd|d}|j||ddS)a& Returns version information from the server. Similar to the ``docker version`` command. Returns: (dict): The server version information Raises: :py:class:`docker.errors.APIError` If the server returns an error. z/version)Z versioned_apiTr#r)r api_versionr rrrversions zDaemonApiMixin.version)NNNN)NNNFN)T) __name__ __module__ __qualname__rZminimum_versionrrrr)r*r,rrrrrs  ; 9r)r$rrrrrrrrrs