File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/smartos.cpython-310.pyc
Back
o ;j � � @ s� d Z ddlZddlZddlZddlmZ ddlZddlZddl Ze� e �Z dZ dd� Zdd� Zd d � Zd d � Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd/d d �Zd d � Zd d!� Zd"d#� Z d$d%� Z d0d&d'�Z d1d)d*�Z d+d,� Z d-d.� Z!dS )2am Management of SmartOS Standalone Compute Nodes :maintainer: Jorge Schrauwen <sjorge@blackdot.be> :maturity: new :depends: vmadm, imgadm :platform: smartos .. versionadded:: 2016.3.0 .. code-block:: yaml vmtest.example.org: smartos.vm_present: - config: reprovision: true - vmconfig: image_uuid: c02a2044-c1bd-11e4-bd8c-dfc1db8b0182 brand: joyent alias: vmtest quota: 5 max_physical_memory: 512 tags: label: 'test vm' owner: 'sjorge' nics: "82:1b:8e:49:e9:12": nic_tag: trunk mtu: 1500 ips: - 172.16.1.123/16 - 192.168.2.123/24 vlan_id: 10 "82:1b:8e:49:e9:13": nic_tag: trunk mtu: 1500 ips: - dhcp vlan_id: 30 filesystems: "/bigdata": source: "/bulk/data" type: lofs options: - ro - nodevices kvmtest.example.org: smartos.vm_present: - vmconfig: brand: kvm alias: kvmtest cpu_type: host ram: 512 vnc_port: 9 tags: label: 'test kvm' owner: 'sjorge' disks: disk0: size: 2048 model: virtio compression: lz4 boot: true nics: "82:1b:8e:49:e9:15": nic_tag: trunk mtu: 1500 ips: - dhcp vlan_id: 30 docker.example.org: smartos.vm_present: - config: auto_import: true reprovision: true - vmconfig: image_uuid: emby/embyserver:latest brand: lx alias: mydockervm quota: 5 max_physical_memory: 1024 tags: label: 'my emby docker' owner: 'sjorge' resolvers: - 172.16.1.1 nics: "82:1b:8e:49:e9:18": nic_tag: trunk mtu: 1500 ips: - 172.16.1.118/24 vlan_id: 10 filesystems: "/config: source: "/vmdata/emby_config" type: lofs options: - nodevices cleanup_images: smartos.image_vacuum .. note:: Keep in mind that when removing properties from vmconfig they will not get removed from the vm's current configuration, except for nics, disk, tags, ... they get removed via add_*, set_*, update_*, and remove_*. Properties must be manually reset to their default value. The same behavior as when using 'vmadm update'. .. warning:: For HVM (bhyve and KVM) brands the `image_uuid` field should go on the boot disks, this disk should NOT have a size specified. (See man vmadm) � N)� OrderedDictZsmartosc C s" dt v r dt v r dS dd�t�fS )z5 Provides smartos state provided for SmartOS � vmadm.create� imgadm.listTFz;{} state module can only be loaded on SmartOS compute nodes)�__salt__�format�__virtualname__� r r �G/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/smartos.py� __virtual__� s ��r c C s6 | r| � d�} t| �dkr| d }| d }||fS dS )z7 Split a smartos docker uuid into repo and tag �:� � r )NN)�split�len)�uuid�tag�repor r r �_split_docker_uuid� s r c C s, | rt dd� | �d�D ��g d�krdS dS )zb Check if uuid is a valid smartos uuid Example: e69a0918-055d-11e5-8912-e3ceb6df4cf8 c s s � | ]}t |�V qd S �N)r )�.0�xr r r � <genexpr>� s � z_is_uuid.<locals>.<genexpr>�-)� � r r � TF)�listr )r r r r �_is_uuid� s $r c C s t | �\}}| o | S )z_ Check if uuid is a valid smartos docker uuid Example plexinc/pms-docker:plexpass )r )r r r r r r �_is_docker_uuid� s r c C s� i } t j�d�rLtjj�dd��4}|D ])}tjj�|�}|d dkr#qd|vr(q|� d�}|d � � � d�| |d � � < qW d � n1 sGw Y t � d | � | S ) z) Loads and parses /usbkey/config �/usbkey/config�rr �#�=r �"Nz(smartos.config - read /usbkey/config: %s)�os�path�isfile�salt�utils�filesZfopen� stringutilsZ to_unicoder �strip�lower�log�debug)�config� config_fileZoptvalr r r � _load_config� s � � r1 c C s� zct jj�dd��J}|�d� tt| �� ��D ]4}dt| | �v r9| | � d�r/| | � d�s9d| | � d�| |< |�t jj � |� d| | � d��� qW d � n1 sVw Y t �d | � W d S tym Y d S w ) z writes /usbkey/config r �wz&# # This file was generated by salt # � r# r" � Nz)smartos.config - wrote /usbkey/config: %sFT)r' r( Z atomicfileZ atomic_open�writer �sorted�items�str� startswith�endswithr* Zto_strr- r. �OSError)r/ r0 �propr r r � _write_config� s& � �� � ��r= c C s� d}t | t�rgt� }| D ]X}||vr| | ||< q t | | t�s!q g ||< | | D ]:}| | | }|||| < d|v rC|d �� |d< d|v r\d�tt|d ���d�d �d��|d< || �|� q)q |S t � d� |S ) z$ Parse vm_present vm config N�macZ vrrp_vridz00:00:5e:00:01:{}r ���r z4smartos.vm_present::parse_vmconfig - failed to parse) � isinstancer r, r �hex�intr �zfill�appendr- �error)r/ Z instances�vmconfigr< �instanceZinstance_configr r r �_parse_vmconfig� s4 ��� �rH c C s~ t | �� �}t |�� �}tjj�| |�}tjj�| |�D ] }||v r-|| d dkr-||= ||v r<|| d dkr<||= q |S )z! get modified properties �old� �new)�set�keysr' r( �dataZ compare_dicts)�current�stateZ current_keysZ state_keys�changedZchanger r r �_get_instance_changes s �rR c C s� d| v r�t d | d ��di �}|�dd�}|�di �}d| vr*d|v r*|d | d< |dkr�d | d< | �dd �| d< d | vrBi | d < |�d i �D ]�}|d | }d |�� � �}|sZqH|dkr�z t�| d �|d��}W n ty } zg }W Y d }~nd }~ww t|t�r�|nt�|�D ]#}|�d�}|D ]} | � |d � d��r�|� | � q�|� d� |�� q�n|| d v r�qHt|t�r�t� |�| d |< qH|| d |< qH| S )N� image_uuid� imgadm.get�manifest�typez zone-dataset�tagsZkernel_version�dockerTz4.3.0�internal_metadataz docker:configzdocker:� docker:envrJ r" r )r �getr, �json�loads� ValueErrorr@ r r r9 �removerD �join�dumps) rF Z imgconfigZimgtypeZimgtags�var�valZ val_config�eZconfig_env_varZ img_env_varr r r � _copy_lx_vars sT ����� �� re c C s | � � } | i ddd�}t� }t|t�r|rdnd}|s d}| |v rUt|| �t|�kr;d|d< d| � d |� d �|d < n3d|d< d | � d |� d �|d < ||d | < ||| < nd|d< d| � d |� d �|d < ||d | < ||| < td s�|d r�t|�|d< |d s�d�| |�|d < |S )z� Ensure configuration property is set to value in /usbkey/config name : string name of property value : string value of property NrJ ��name�changes�result�comment�true�falseTri � property z already has value "r# rj zupdated property z with value "rh zadded property �testz3Could not add property {} with value "{}" to config)r, r1 r@ �boolr8 �__opts__r= r )rg �value�retr/ r r r �config_presentT s6 ��rs c C s� | � � } | i ddd�}t� }| |v r(d|d< d| � d�|d< d|d | < || = n d|d< d| � d �|d< td sB|d rBt|�|d< |S ) zp Ensure configuration property is absent in /usbkey/config name : string name of property NrJ rf Tri rm � deletedrj rh � is absentrn )r, r1 rp r= )rg rr r/ r r r � config_absent� s rv �imgapic C s� | i ddd�}| t d � v r d|d< d| � d�|d < |S td r'i }d|d< n t d | |�}| |v |d< |d rHd| � d �|d < d |d | < |S d| � d�|d < d|v r`d�|d |d �|d < |S )z� Ensure an image source is present on the computenode name : string source url source_type : string source type (imgapi or docker) NrJ rf �imgadm.sourcesTri � image source � is presentrj rn zimgadm.source_addz addedZaddedrh z not added�Error�{}: {}�r rp r )rg Z source_typerr �resr r r �source_present� s$ � �r c C s� | i ddd�}| t d � vr d|d< d| � d�|d < |S td r'i }d|d< n t d | �}| |v|d< |d rGd| � d �|d < d |d | < |S d| � d�|d < d|v r_d�|d |d �|d < |S )zc Ensure an image source is absent on the computenode name : string source url NrJ rf rx Tri ry ru rj rn zimgadm.source_deletert Zdeletedrh z not deletedr{ r| r} )rg rr r~ r r r � source_absent� s$ � �r� c C sX | i ddd�}t | �r#td | �r#d|d< d�| td | ��|d< |S | td � v r8d|d< d | � d �|d< |S t | �r@| g}ntd � }| |v r�td rcd|d< i }t | �r\| |d< n&|| || < n td | �}t| �rt| |v |d< nt | �r�td | �du|d< |d r�d | � d�|d< ||d< |S d | � d�|d< |S d|d< d | � d�|d< |S )z] Ensure image is present on the computenode name : string uuid of image NrJ rf �imgadm.docker_to_uuidTri zimage {} ({}) is presentrj r �image rz z imgadm.availrn z$00000000-0000-0000-0000-000000000000� imgadm.importz importedrh z was unable to be importedFz does not exists)r r r rp r )rg rr Zavailable_imagesr~ r r r � image_present� sH �'� � ��r� c C s` | i ddd�}d}t | �r| }t| �rtd | �}|r"|td � vr0d|d< d| � d �|d < |S |td d d �v rGd|d< d| � d�|d < |S td rPd|d< n<td |�}d}|d d dkr�|r�|d7 }td |d d � d|d v r�td |d d �}nd}|sbntd |� |td � v|d< |r�d�| |�|d < nd| � d�|d < d|d | < |S ) z� Ensure image is absent on the computenode name : string uuid of image .. note:: computenode.image_absent will only remove the image if it is not used by a vm. NrJ rf r� r Tri r� ru rj � vmadm.listrS ��orderFz currently in use by a vmrn rT r rU rg � docker-layerr � imgadm.deleter �originz image {} and {} children deletedrt rh )r r r rp r )rg rr r �imageZ image_countr r r � image_absent$ sH #� � �� � r� c C s� | � � } | i ddd�}g }td � D ]C}d|vrq|d tkr q|d dvr'qd|v rUt|d �r9|�|d � qt|d �rUtd |d �|d< |d sNq|�|d � qtd d d �D ] }||vrh|�|� q]d |d< td � D ]a}||v ryqrtd |�}|d d dkr�|r�|d d }|td |�v r�d|d |< nd|d< d|d< d|d v r�td |d d �}nd}|s�qr|td |�v r�d|d |< qrd|d< d|d< qr|d r�|d s�d|d< |S |d r�|d r�d|d< |S ) z� Delete images not in use or installed via image_present .. warning:: Only image_present states that are included via the top file will be detected. NrJ rf zstate.show_lowstaterP Zfun)r� rg r� r� rS r� Tri r rT rU r� r r� rh Fzfailed to delete imagesrj r� zno images deletedzimages deleted)r, r r r rD r )rg rr ZimagesrP rS r� r r r � image_vacuuma sd � � �� �r� c C sT | � � } | i ddd�}|r|ni }ddddddddd�}|�|� t�d| |� g d�d d d d d �d gd�}ddg}g d�}t||d �}t�d| |� d|vrT| |d< d|v r�td |d �}|rd|n|d |d< |d td � vr�|d r�td s�td |d �} td |d �|d< |d | vr�d|d< d �|d �|d < n d|d< d �|d �|d < d |v r�|d ng D ]@} d| v r�| d td � vr�|d r�td s�td | d �} | d | vr�d|d< d �| d �|d < q�d|d< d �| d �|d < q�d |v �r$|D ]#} | |d v�r �q t|d | t ��r"t � |d | �|d | < �q |d! d"k�r4|d# �r4t |�}|d du �r=|S |d td$ dd%�v �r@d|d< |td& |d dd'�i dd(�}d|d) v �ru|d) d |d*< |d+ d |d) d< d |d) v �r�g } |d) d D ]6} d} d |d+ v �r�|d+ d D ]}|d � | d ��r�|d } n�q�| �s�| d = n| | d < | �| � �q�| |d) d < |d) D ]d}||d v �s�||d, v �s�||d- v �rސq�||d+ v �r t|d+ | t ��s�t|d+ | t��r |d+ | |d) | k�r�q�nd.�|d+ | �d.�|d) | �k�r �q�|d) | |d/ |< �q�|d, D �]}||d- v �r:�q.|d0|� � }t�d1||� |d k�r�|d) �d2d��r�d |d) v�rci |d) d < |D ] } |d+ �|i ��| d�}|du�r�||d) d | < �qe||d) v �r�|d) | du�r�|d) | D ]Q}||d+ | v �r�|d+ | | |d) | | k�r��q�|�s�||d+ | v �rĐq�d3|� �|d/ v�r�i |d/ d3|� �< |d) | | |d/ d3|� � |< �q�|�rA||d+ v �rA|d+ | du�rA|d+ | D ]=}||d) v �r |d) | du�r ||d) | v �r �qd4|� �|d/ v�r3g |d/ d4|� �< |d/ d4|� � �|� �q�q.|d D �]Q}||d- v �rS�qG||d) v �r |d) | du�r |d) | D ]�}d}|d+ | D ]�}|d | |v�r��qs||d | ||d | k�r�d}t||�}i }|D ] }|| ||< �q�|D ] }t|| t ��r�|| �s��q�||v�r�|| ||< �q�|�r�d5|� �|d/ v�r�g |d/ d5|� �< ||d | ||d | < |d/ d5|� � �|� �qs|�rd6|� �|d/ v�rg |d/ d6|� �< |d/ d6|� � �|� �qi||d+ v �r�|d+ | du�r�|d+ | D ]e}d}||d) v �rn|d) | du�rn|d) | D ]!}|d | |v�rY�qL||d | ||d | k�rld}�qL|�r�d4|� �|d/ v�r�g |d/ d4|� �< |d/ d4|� � �||d | � �q2�qGd}td �s!|d/ �r!|d+ d! d7k�r�|d8 �r�d9|d/ v �s�d:|d/ v �s�d;|d/ v �r�|d) d td$ dd<d=�v �r�d}td> |d) d dd?� td@ dP|d) d dd?�|d/ ��}t|t��sdA|v �rd|d< d.�|dA �|d < nd|d< |d/ |dB |d) d < |d �r td �r7|d/ |dB |d) d < |d) d |dB v �r�|dB |d) d �r�dC�|d) d �|d < |d8 �r�|d+ d! d7k�r�td �s�|d) d td$ dd<d=�v �r�tdD |d) d dd?� |�r�tdE |d) d dd?� ni |dB< dF�|d) d �|d < d|d+ v �r |d* |d+ d k�r |dG �rtdH |d) d d|d* dI�}t|t��s�dA|v �r�d|d< dJ�|d) d �|d < |S dK�|d) d �|d < |d) d |dB v�ri |dB |d) d < |d* |dB |d) d d< |S t�dL| � |S dM�|d) d �|d < t|t��s>dA|v �r>d.�|dA �|d < |S d|d< d |v �rdg } |d D ]} d | v �rY| d = | �| � �qO| |d < |d �r�td �swtdN dPi |��nd} t| t��s�dA| v �r�d|d< d.�| dA �|d < |S d|d< ||dB |d < dO�|d �|d < |S )Qa� Ensure vm is present on the computenode name : string hostname of vm vmconfig : dict options to set for the vm config : dict fine grain control over vm_present .. note:: The following configuration properties can be toggled in the config parameter. - kvm_reboot (true) - reboots of kvm zones if needed for a config update - auto_import (false) - automatic importing of missing images - auto_lx_vars (true) - copy kernel_version and docker:* variables from image - reprovision (false) - reprovision on image_uuid changes - enforce_tags (true) - false = add tags only, true = add, update, and remove tags - enforce_routes (true) - false = add tags only, true = add, update, and remove routes - enforce_internal_metadata (true) - false = add metadata only, true = add, update, and remove metadata - enforce_customer_metadata (true) - false = add metadata only, true = add, update, and remove metadata .. note:: State ID is used as hostname. Hostnames must be unique. .. note:: If hostname is provided in vmconfig this will take president over the State ID. This allows multiple states to be applied to the same vm. .. note:: The following instances should have a unique ID. - nic : mac - filesystem: target - disk : path or diskN for zvols e.g. disk0 will be the first disk added, disk1 the 2nd,... .. versionchanged:: 2019.2.0 Added support for docker image uuids, added auto_lx_vars configuration, documented some missing configuration options. NrJ rf TF)� kvm_reboot� auto_import� auto_lx_vars� reprovisionZ enforce_tagsZenforce_routesZenforce_internal_metadataZenforce_customer_metadataz#smartos.vm_present::%s::config - %s)rW Zcustomer_metadatarY Zroutesr> r% �target)Znics�disks� filesystemsZ pci_devicesr� )� collectionrG � create_onlyz docker:idzdocker:restartcount)rZ z docker:cmdzdocker:entrypointrG z%smartos.vm_present::%s::vmconfig - %s�hostnamerS r� r r� rn r� ri zfailed to import image {}rj zimage {} not installedr� rY ZbrandZlxr� r� r� z vmadm.get��key)rP rO rQ �reprovision_uuidrP r� rO r� r� z{}rQ Zenforce_z#smartos.vm_present::enforce_%s = %srX Zset_Zremove_Zupdate_Zadd_Zkvmr� Z add_disksZ update_disksZ remove_disks� state=running�r� �search� vmadm.stop)�vmr� � vmadm.updater{ rh z vm {} updatedz vmadm.reboot� vmadm.startzvm {} is up to dater� zvmadm.reprovision)r� r� r� z!vm {} updated, reprovision failedz vm {} updated and reprovisionedzismartos.vm_present::%s::reprovision - image_uuid in state does not match current, reprovision not allowedzvm {} failed to be updatedr z vm {} createdr )r, �updater- r. rH r rp r r@ r r\ ra re r: rD �dictr[ rR ro �warning) rg rF r/ rr Z state_configZ vmconfig_typeZvmconfig_docker_keepZvmconfig_docker_arrayZ docker_uuidr~ Zdiskrb Z new_disksr% Zcdiskr< r� Zenforcerc rG Z state_cfgZ add_instanceZ current_cfgrQ Z update_cfgZremove_instanceZkvm_needs_startZrretr r r r � vm_present� s� . � �� �� �� ��� ���� �� �� ����� �� �� ��������� � � �� ��� � � �� � � �3� ��*��&� �� ��r� Fc C s� | � � } | i ddd�}| td dd�vr"d|d< d | � d �|d < |S td s<|r1td | ddd� td | dd�|d< nd|d< t|d t�s[|d �d�r[d|d< d| � �|d < |S d | � d�|d < d|d | < |S )z� Ensure vm is absent on the computenode name : string hostname of vm archive : boolean toggle archiving of vm on removal .. note:: State ID is used as hostname. Hostnames must be unique. NrJ rf r� r� r� Tri �vm ru rj rn r� )r� r� Zarchive_on_deletez vmadm.deleter� r{ Fzfailed to delete vm rt rh �r, r rp r@ ro r[ )rg �archiverr r r r � vm_absent� s( �� � r� c C � | � � } | i ddd�}| td ddd�v r#d|d < d | � d �|d < |S td r)dntd | dd�|d < t|d t�sN|d �d�rNd|d < d| � �|d < |S d|d | < d | � d�|d < |S )z� Ensure vm is in the running state on the computenode name : string hostname of vm .. note:: State ID is used as hostname. Hostnames must be unique. NrJ rf r� r� r� r� Tri r� z already runningrj rn r� r� r{ Fzfailed to start Zrunningrh z startedr� �rg rr r r r � vm_running� � �� �r� c C r� )z� Ensure vm is in the stopped state on the computenode name : string hostname of vm .. note:: State ID is used as hostname. Hostnames must be unique. NrJ rf r� r� z state=stoppedr� Tri r� z already stoppedrj rn r� r� r{ Fzfailed to stop �stoppedrh z stoppedr� r� r r r � vm_stopped� r� r� )rw r )F)"�__doc__r\ �loggingr$ � collectionsr Zsalt.utils.atomicfiler' Zsalt.utils.dataZsalt.utils.files� getLogger�__name__r- r r r r r r1 r= rH rR re rs rv r r� r� r� r� r� r� r� r� r r r r �<module> sD x #:6 #!6= N , "
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings