File: //opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/pbm.cpython-310.pyc
o
�N�g�Q � @ s� d Z ddlZddlZddlZddlmZmZ ddlmZ ddl m
Z
z
ddl m Z dZ
W n ey7 dZ
Y nw e�e�Zd d
� Zd d � Zd
d� Zdd� Zdd� ZdS )aY
Manages VMware storage policies
(called pbm because the vCenter endpoint is /pbm)
Examples
========
Storage policy
--------------
.. code-block:: python
{
"name": "salt_storage_policy"
"description": "Managed by Salt. Random capability values.",
"resource_type": "STORAGE",
"subprofiles": [
{
"capabilities": [
{
"setting": {
"type": "scalar",
"value": 2
},
"namespace": "VSAN",
"id": "hostFailuresToTolerate"
},
{
"setting": {
"type": "scalar",
"value": 2
},
"namespace": "VSAN",
"id": "stripeWidth"
},
{
"setting": {
"type": "scalar",
"value": true
},
"namespace": "VSAN",
"id": "forceProvisioning"
},
{
"setting": {
"type": "scalar",
"value": 50
},
"namespace": "VSAN",
"id": "proportionalCapacity"
},
{
"setting": {
"type": "scalar",
"value": 0
},
"namespace": "VSAN",
"id": "cacheReservation"
}
],
"name": "Rule-Set 1: VSAN",
"force_provision": null
}
],
}
Dependencies
============
- pyVmomi Python Module
pyVmomi
-------
PyVmomi can be installed via pip:
.. code-block:: bash
pip install pyVmomi
.. note::
Version 6.0 of pyVmomi has some problems with SSL error handling on certain
versions of Python. If using version 6.0 of pyVmomi, Python 2.6,
Python 2.7.9, or newer must be present. This is due to an upstream dependency
in pyVmomi 6.0 that is not supported in Python versions 2.7 to 2.7.8. If the
version of Python is not in the supported range, you will need to install an
earlier version of pyVmomi. See
`Issue #29537 <https://github.com/saltstack/salt/issues/29537>` for more
information.
� N)�ArgumentValueError�CommandExecutionError)�recursive_diff)� list_diff)� VmomiSupportTFc C s. t sdS dtjv rtjdkrtjdk rdS dS )N)Fz,State module did not load: pyVmomi not foundz vim25/6.0)� � )r r � )FzaState module did not load: Incompatible versions of Python and pyVmomi present. See Issue #29537.T)� HAS_PYVMOMIr Z
versionMap�sys� version_info� r
r
�C/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/pbm.py� __virtual__q s
r c C s dS )z
Init function
Tr
)�lowr
r
r �mod_init� s r c
C s� t �|�}td � }t�d|� t|� d� � d }t�d| |� t�d|� d}| i ddd �}g }i }d}d} �zTtd
� } td | �}
t�d |
� |�d
�r�t|d
�dkr\td��|d
d } |
d
d } t | d | �dg �dd�}
|d
= | �d�r�| d= | d= t
| t | ��}|
d
= t
|
|�}|j s�|
j s�|j �r�d|j
v s�d|j
v r�td��d}td �rg }|j r�|�dd� |j�d�D �� |j s�|
j r�|�d � |j r�|�d d� |j�d�D �� |
j r�|�d � |�d d� |
j�d�D �� |�d �| |d�|��� ntd! |
d || d"� |�d#|� d$�� t�|d% � |j
}|j
g|d
< |
j
|d
d d< |d
d d �sA|d
d d= |d
d �sK|d
= |j}|jg|d
< |
j|d
d d< |d
d d �sm|d
d d= |d
d �sw|d
= |�d&||d'�i� t�|� td( | � W n= t�y� } z0t�d)|� | �r�td( | � td �s�d|d*< |�|jtd �s�dndd+�� |W Y d}~S d}~ww |�s�|�d,�|�dd+�� |S |�d�|�|td �r�dndd-�� |S ).z�
Configures the default VSAN policy on a vCenter.
The state assumes there is only one default VSAN policy on a vCenter.
policy
Dict representation of a policy
�vsphere.get_proxy_type�proxy_type = %s� .get_details�vcenterzRunning %s on vCenter '%s'z policy = %sFN��name�changes�result�comment�&vsphere.get_service_instance_via_proxyz vsphere.list_default_vsan_policyzcurrent_policy = %s� subprofiles� �AMultiple sub_profiles ({0}) are not supported in the input policyr � capabilities�id��keyr � descriptionzE'name' and 'description' of the default VSAN policy cannot be updatedT�testc S � g | ]}|�qS r
r
��.0Zchanger
r
r �
<listcomp>� � z2default_vsan_policy_configured.<locals>.<listcomp>�
� subprofiles:c S � g | ]}d |� ��qS �z r
r& r
r
r r( � � ��� capabilities:c S r, r- r
r& r
r
r r( � r. z@State {} will update the default VSAN policy on vCenter '{}':
{}� vsphere.update_storage_policy��policyZ policy_dict�service_instancez,Updated the default VSAN policy in vCenter '�'���Zdefault_vsan_policy��new�old�vsphere.disconnect� Error: %sr �r r zPDefault VSAN policy in vCenter '{}' is correctly configured. Nothing to be done.�r r r )�copy�deepcopy�__salt__�log�trace�info�get�lenr r r �dict�diffs�
new_values�__opts__�extend� changes_str�split�append� changes_str2�format�join�
old_values�updater �error�strerror)r r2 � policy_copy�
proxy_typer �changes_required�ret�commentsr �si�current_policy�
subprofile�current_subprofile�capabilities_differ�subprofile_differ�
policy_differ� str_changesrG rP �excr
r
r � default_vsan_policy_configured� s
�
�
�
�
��
�����
�
��
�� �
���
�����rb c s� g }g }d}| i ddd�}t �d|� d}�z�td � }t �d|� t|� d� � d }t �d | |� td
� }td d d
� |D �|d�} t �d| � |D �]�� t�� �}
� fdd
�| D �} | rd| d nd} | s�d}td r{|�d�| � d |�� n td � d � |d� |�d�� d |�� |�� dd�� t �|d � qM� � d�r�t
� d �d kr�t d ��� d d }
| d d }t |d |
� d g �d d �}� d= |
� d �r�|
d = |d = t
|t|
��}| d= t
| � �}|js�|js�|j�r�d}td �rTg }|j�r
|�d!d
� |j�d"�D �� |j�s|j�rC|�d#� |j�r,|�d$d
� |j�d"�D �� |j�rC|�d%� |�d&d
� |j�d"�D �� |�d'�| � d |d"�|��� ntd( | d |
|d)� |�d*�� d |�� t �|d � |j}|jg|d< |j|d d d < |d d d �s�|d d d = |d d �s�|d= |j}|jg|d< |j|d d d < |d d d �s�|d d d = |d d �s�|d= |�||d�� qM|�d+�� d �� qMtd, |� W n= t�y! } z0t �d-|� |�r�td, |� td �sd|d.< |�|jtd �sdndd/�� |W Y d}~S d}~ww |�s2|�d0�|�dd/�� |S |�d"�|�d1|itd �rBdndd2�� |S )3z�
Configures storage policies on a vCenter.
policies
List of dict representation of the required storage policies
FNr z
policies = %sr r r r z"Running state '%s' on vCenter '%s'r z vsphere.list_storage_policiesc S s g | ]}|d �qS �r r
)r' r2 r
r
r r( F s z/storage_policies_configured.<locals>.<listcomp>)Z policy_namesr3 zcurrent_policies = %sc s g | ] }|d � d kr|�qS rc r
)r' �p�r2 r
r r( M s r Tr$ z<State {} will create the storage policy '{}' on vCenter '{}'r z vsphere.create_storage_policy)r3 z+Created storage policy '{}' on vCenter '{}'r6 r5 r r r r r r! c S r% r
r
r& r
r
r r( � r) r* r+ c S r, r- r
r& r
r
r r( � r. r/ c S r, r- r
r& r
r
r r( � r. z@State {} will update the storage policy '{}' on vCenter '{}':
{}r0 r1 z/Updated the storage policy '{}' in vCenter '{}'z6Storage policy '{}' is up to date. Nothing to be done.r9 r: r r; zOAll storage policy in vCenter '{}' is correctly configured. Nothing to be done.Zstorage_policiesr< )r@ rA r? rB r= r> rH rL rN rC rD r r r rE rF rI rJ rK rM rO rG rP r rR rQ rS )r ZpoliciesrX r rV rW rY rU r Zcurrent_policiesrT Zfiltered_policiesrZ r[ r\ r] r^ r_ r` rG rP ra r
re r �storage_policies_configured/ s@
�
��
���
�
�
���
�
���
�������
��
����
���
�����rf c
C sT t �d| ||� i }d}| i ddd�}d}zGtd � }td ||d�}|d |kr0d �||�}n&d
}d |d |d �i}td
rGd�| ||�}ntd |||d� d�|| �}t �|� W n1 ty� } z%t �d| � |rrtd |� |�| jtd
s|dndd�� |W Y d} ~ S d} ~ ww ||d< |r�|�|td
r�dnd
d�� |S d
|d< |S )z�
Assigns a default storage policy to a datastore
policy
Name of storage policy
datastore
Name of datastore
z1Running state %s for policy '%s', datastore '%s'.FNr r z0vsphere.list_default_storage_policy_of_datastore)� datastorer3 r zNStorage policy '{}' is already assigned to datastore '{}'. Nothing to be done.TZdefault_storage_policy)r8 r7 r$ z;State {} will assign storage policy '{}' to datastore '{}'.z2vsphere.assign_default_storage_policy_to_datastore)r2 rg r3 z2Storage policy '{} was assigned to datastore '{}'.r: r9 r; r )r r r ) r@ rB r? rN rH r rR rQ rS )
r r2 rg r rV rW rY Zexisting_policyr ra r
r
r � default_storage_policy_assigned� sb
�
� ������ ��� �rh )�__doc__r= �loggingr Zsalt.exceptionsr r Zsalt.utils.dictdifferr Zsalt.utils.listdifferr ZpyVmomir r
� ImportError� getLogger�__name__r@ r r rb rf rh r
r
r
r �<module> s* \ �
% E