File: //proc/1233/cwd/usr/lib/python3/dist-packages/docker/api/__pycache__/plugin.cpython-310.pyc
o
�2.a�" � @ s" d dl mZmZ G dd� d�ZdS )� )�auth�utilsc @ s e Zd Ze�d�e�d�dd� ��Ze�d�d dd��Ze�d�dd � �Ze�d�d d d ��Z e�d�d
d� �Z
e�d�d dd��Z e�d�dd� �Z e�d�dd� �Z
e�d�e�d�dd� ��Ze�d�e�d�d dd���Ze�d�e�d�dd � ��ZdS ) �PluginApiMixinz1.25�namec C sH | � d|�}|}t|t�rdd� |�� D �}| j||d�}| �|� dS )aC
Configure a plugin.
Args:
name (string): The name of the plugin. The ``:latest`` tag is
optional, and is the default if omitted.
options (dict): A key-value mapping of options
Returns:
``True`` if successful
z/plugins/{0}/setc S s g | ] \}}|� d |� ��qS )�=� )�.0�k�vr r �3/usr/lib/python3/dist-packages/docker/api/plugin.py�
<listcomp> s z3PluginApiMixin.configure_plugin.<locals>.<listcomp>)�dataT)�_url�
isinstance�dict�items�
_post_json�_raise_for_status)�selfr �options�urlr
�resr r r �configure_plugin s
z PluginApiMixin.configure_pluginFc C sj | � d�}tj||ttj�|g ��d��}| j|d|i|d�}W d � n1 s)w Y | �|� dS )a*
Create a new plugin.
Args:
name (string): The name of the plugin. The ``:latest`` tag is
optional, and is the default if omitted.
plugin_data_dir (string): Path to the plugin data directory.
Plugin data directory must contain the ``config.json``
manifest file and the ``rootfs`` directory.
gzip (bool): Compress the context using gzip. Default: False
Returns:
``True`` if successful
z/plugins/create)�root�gzip�filesr )�paramsr
NT)r r �create_archive�set�build�walk�_postr )r r �plugin_data_dirr r �archvr r r r �
create_plugin s
� �
z PluginApiMixin.create_pluginc C s$ | � d|�}| �|�}| �|� dS )a
Disable an installed plugin.
Args:
name (string): The name of the plugin. The ``:latest`` tag is
optional, and is the default if omitted.
Returns:
``True`` if successful
z/plugins/{0}/disableT�r r! r )r r r r r r r �disable_plugin5 s
z PluginApiMixin.disable_plugin� c C s0 | � d|�}d|i}| j||d�}| �|� dS )aV
Enable an installed plugin.
Args:
name (string): The name of the plugin. The ``:latest`` tag is
optional, and is the default if omitted.
timeout (int): Operation timeout (in seconds). Default: 0
Returns:
``True`` if successful
z/plugins/{0}/enable�timeout�r Tr% )r r r( r r r r r r �
enable_pluginF s
z PluginApiMixin.enable_pluginc C s | � d|�}| �| �|�d�S )a
Retrieve plugin metadata.
Args:
name (string): The name of the plugin. The ``:latest`` tag is
optional, and is the default if omitted.
Returns:
A dict containing plugin info
z/plugins/{0}/jsonT�r �_result�_get)r r r r r r �inspect_pluginY s z PluginApiMixin.inspect_pluginNc C st | � d�}d|i}|r||d< i }t�|�\}}t�| |�} | r$| |d< | j||||dd�}
| �|
� | j|
dd�S )a
Pull and install a plugin. After the plugin is installed, it can be
enabled using :py:meth:`~enable_plugin`.
Args:
remote (string): Remote reference for the plugin to install.
The ``:latest`` tag is optional, and is the default if
omitted.
privileges (:py:class:`list`): A list of privileges the user
consents to grant to the plugin. Can be retrieved using
:py:meth:`~plugin_privileges`.
name (string): Local name for the pulled plugin. The
``:latest`` tag is optional, and is the default if omitted.
Returns:
An iterable object streaming the decoded API logs
z
/plugins/pull�remoter �X-Registry-AuthT�r �headersr
�stream��decode�r r �resolve_repository_name�get_config_headerr r �_stream_helper) r r/ �
privilegesr r r r2 �registry� repo_name�header�responser r r � pull_pluginh s
� �
zPluginApiMixin.pull_pluginc C s | � d�}| �| �|�d�S )z�
Retrieve a list of installed plugins.
Returns:
A list of dicts, one per plugin
z/pluginsTr+ )r r r r r �plugins� s
zPluginApiMixin.pluginsc C sT d|i}i }t �|�\}}t �| |�}|r||d< | �d�}| �| j|||d�d�S )al
Retrieve list of privileges to be granted to a plugin.
Args:
name (string): Name of the remote plugin to examine. The
``:latest`` tag is optional, and is the default if omitted.
Returns:
A list of dictionaries representing the plugin's
permissions
r/ r0 z/plugins/privileges)r r2 T)r r7 r8 r r, r- )r r r r2 r; r< r= r r r r �plugin_privileges� s �
�z PluginApiMixin.plugin_privilegesc C s\ | � d|�}i }t�|�\}}t�| |�}|r||d< | j||d�}| �|� | j|dd�S )a
Push a plugin to the registry.
Args:
name (string): Name of the plugin to upload. The ``:latest``
tag is optional, and is the default if omitted.
Returns:
``True`` if successful
z/plugins/{0}/pullr0 )r2 Tr4 )r r r7 r8 r! r r9 )r r r r2 r; r< r= r r r r � push_plugin� s
zPluginApiMixin.push_pluginc C s, | � d|�}| j|d|id�}| �|� dS )a�
Remove an installed plugin.
Args:
name (string): Name of the plugin to remove. The ``:latest``
tag is optional, and is the default if omitted.
force (bool): Disable the plugin before removing. This may
result in issues if the plugin is in use by a container.
Returns:
``True`` if successful
z /plugins/{0}�forcer) T)r �_deleter )r r rC r r r r r �
remove_plugin� s
z PluginApiMixin.remove_pluginz1.26c C sj | � d|�}d|i}i }t�|�\}}t�| |�} | r | |d< | j||||dd�}
| �|
� | j|
dd�S )a�
Upgrade an installed plugin.
Args:
name (string): Name of the plugin to upgrade. The ``:latest``
tag is optional and is the default if omitted.
remote (string): Remote reference to upgrade to. The
``:latest`` tag is optional and is the default if omitted.
privileges (:py:class:`list`): A list of privileges the user
consents to grant to the plugin. Can be retrieved using
:py:meth:`~plugin_privileges`.
Returns:
An iterable object streaming the decoded API logs
z/plugins/{0}/upgrader/ r0 Tr1 r4 r6 ) r r r/ r: r r r2 r; r< r= r> r r r �upgrade_plugin� s � �
z PluginApiMixin.upgrade_plugin)F)r' )N)�__name__�
__module__� __qualname__r �minimum_version�check_resourcer r$ r& r* r. r? r@ rA rB rE rF r r r r r s6
%
r N)� r r r r r r r �<module> s