File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/glassfish.cpython-310.pyc
Back
o ;j6U � @ s� d Z ddlZddlmZ zddlZdZW n ey dZY nw dd� Zdd � Z d d � Z d,d d �Z d,dd�Z d-dd�Z d.dd�Z d/d d �Zd,d d �Z ! " # d0d$d%�Zd.d&d'�Zd,d(d)�Zd,d*d+�ZdS )1a) Manage Glassfish/Payara server .. versionadded:: 2016.11.0 Management of glassfish using its RESTful API You can setup connection parameters like this .. code-block:: yaml - server: - ssl: true - url: localhost - port: 4848 - user: admin - password: changeit � N)�CommandExecutionErrorTFc C s dt v rtrdS dS )z4 Only load if glassfish module is available z glassfish.enum_connector_c_poolT)Fz$glassfish module could not be loaded)�__salt__�HAS_LIBS� r r �I/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/glassfish.py� __virtual__ s r c C sV i }| � � D ]"\}}t|t�s$t|t�rt|�||< qt|��� ||< q|||< q|S )z@ Encode json values in unicode to match that of the API )�items� isinstance�str�dict�_json_to_unicode�lower)�data�ret�key�valuer r r r & s r c C s� i }t tjj�tjjj|dd���}tjj�tjjj| dd��} | �� D ]/\}}t|��� }||v r:t|| ��� }|dksB|dkrDd}||v rS||krS||d�||< q$|S )z? Compare the API results to the current statefile data F)� ensure_ascii�null�none� )�old�new) r �salt�utils�json�loads�dumpsr r r )Zold_confZnew_conf�changedr r ZoldvalZnewvalr r r � _is_updated6 s" �� �r c C s� i dddd�}z t d|� � � }W n0 tjyA } z#td r1| |d�|d< d|d < |W Y d}~S d |d < |W Y d}~S d}~ww |rH| |vr�| |d�|d< d|d < td s�zt d |� � | fd |i|�� W |S ty� } z ||d < |W Y d}~S d}~ww |S |r�t|�r�t d|� � | |d�}t||�}|r�d|d< ||d< td s�zt d|� � | fd |i|�� W |S ty� } z ||d < W Y d}~|S d}~ww |S )z9 Generic function to create or update an element FN)�changes�update�create�error�glassfish.enum_�test)�NameZParamsr Tr! �Can't connect to the serverr" zglassfish.create_�serverzglassfish.get_�r' r zglassfish.update_)r �requests�ConnectionError�__opts__r �anyr ) �name� elem_typer r' r �elementsr" Z current_dataZ data_diffr r r �_do_element_presentO s^ �� ��� � ������r0 c C s� ddd�}z t d|� � � }W n) tjy8 } z td r(d|d< |W Y d}~S d|d < |W Y d}~S d}~ww |rq| |v rqd|d < td sqzt d |� � | fd |i|�� W |S typ } z ||d < W Y d}~|S d}~ww |S ) z/ Generic function to delete an element FN)�deleter" r# r$ Tr! r& r" r1 zglassfish.delete_r' �r r) r* r+ r )r- r. r r' r r/ r" r r r �_do_element_absentx s. �� ���r3 �connection_factoryr � � � �, �< c C s4 | ddi d�} i }i }| � d�}|dkrd|d< n |dkr"d|d< n|d kr+d |d< n d | d < d | d< | S ||d< ||d< ||d< ||d< ||d< ||d< ||d< ||d< |d |d< | |d< | r�| dkrjd|d< n | d krsd |d< n| d kr|d |d< n d | d < d | d< | S | |d!< t |d"|| �}t | d#|| �}|d$ �s|d$ �std% s�d&| d < |d' s�|d' r�|d( | d( d)< |d( | d( d*< td% r�d+| d< | S d,| d< | S |d- s�|d- r�|d( | d( d)< |d( | d( d*< td% r�d.| d< | S d/| d< | S d&| d < i | d(< d0| d< | S d | d < d1�|d$ |d$ �| d< | S )2a: Ensures that the Connection Factory is present name Name of the connection factory restype Type of the connection factory, can be either ``connection_factory``, ``queue_connection_factory` or ``topic_connection_factory``, defaults to ``connection_factory`` description Description of the connection factory enabled Is the connection factory enabled? defaults to ``true`` min_size Minimum and initial number of connections in the pool, defaults to ``1`` max_size Maximum number of connections that can be created in the pool, defaults to ``250`` resize_quantity Number of connections to be removed when idle_timeout expires, defaults to ``2`` idle_timeout Maximum time a connection can remain idle in the pool, in seconds, defaults to ``300`` wait_timeout Maximum time a caller can wait before timeout, in seconds, defaults to ``60`` reconnect_on_failure Close all connections and reconnect on failure (or reconnect only when used), defaults to ``false`` transaction_support Level of transaction support, can be either ``XATransaction``, ``LocalTransaction`` or ``NoTransaction`` connection_validation Connection validation is required, defaults to ``false`` N�r- �result�commentr �-Connection-PoolZtopic_connection_factoryz javax.jms.TopicConnectionFactoryZconnectionDefinitionNameZqueue_connection_factoryz javax.jms.QueueConnectionFactoryr4 zjavax.jms.ConnectionFactoryFr; �Invalid restyper< � description�enabled�poolName�steadyPoolSize� maxPoolSize�poolResizeQuantity�idleTimeoutInSeconds�� �maxWaitTimeInMillisZfailAllConnectionsZxa_transactionZ XATransactionZtransactionSupportZlocal_transactionZLocalTransactionZno_transactionZ NoTransactionzInvalid transaction_supportZ isConnectionValidationRequired�connector_c_poolZconnector_resourcer" r$ Tr! r �pool�resourcez$Connection factory set to be createdzConnection factory createdr z$Connection factory set to be updatedzConnection factory updatedz(Connection factory is already up-to-date�ERROR: {} // {}�r0 r+ �format)r- �restyper? r@ �min_size�max_size�resize_quantity� idle_timeout� wait_timeoutZreconnect_on_failureZtransaction_supportZconnection_validationr' r � pool_data�res_data� pool_name�pool_ret�res_retr r r �connection_factory_present� s| 7 �� � ��rY c C s� | ddi d�}| � d�}t |dd|i|�}|d s?td r'|d r'd |d < |S |d r5d |d < d |d < |S d |d < d|d < |S d|d < d�|d �|d < |S )z� Ensures the transaction factory is absent. name Name of the connection factory both Delete both the pool and the resource, defaults to ``true`` Nr: r= rH �cascader" r$ r1 z$Connection Factory set to be deletedr< Tr; zConnection Factory deletedz Connection Factory doesn't existF� Error: {}�r3 r+ rM )r- �bothr' r rV rW r r r �connection_factory_absent s& � ���r^ �queuec C sF | ddi d�}i }|dkrd|d< d|d< n|dkr#d |d< d |d< n d |d < d |d< |S d|i|d< ||d< ||d< t | d||�}|d s�td sNd|d < |d r\td r\d|d< |S |d rl|d |d< d|d< |S |d rztd rzd |d< |S |d r�|d |d< d |d< |S d|d < d |d< |S d |d < d �|d �|d< |S ) a| Ensures that the JMS Destination Resource (queue or topic) is present name The JMS Queue/Topic name physical The Physical destination name restype The JMS Destination resource type, either ``queue`` or ``topic``, defaults is ``queue`` description A description of the resource enabled Defaults to ``True`` Nr: r_ zjavax.jms.Queue�resTypezcom.sun.messaging.QueueZ classNameZtopiczjavax.jms.Topiczcom.sun.messaging.TopicFr; r> r< r% � propertiesr? r@ �admin_object_resourcer" r$ Tr! zJMS Queue set to be createdr zJMS queue createdr zJMS Queue set to be updatedzJMS Queue updatedz JMS Queue already up-to-datezError from API: {}rL ) r- ZphysicalrN r? r@ r' r �params�jms_retr r r �destination_present. sL � � � ��re c C s� | ddi d�}t | di |�}|d s8td r |d r d|d< |S |d r.d |d < d |d< |S d |d < d |d< |S d |d < d�|d �|d< |S )zg Ensures that the JMS Destination doesn't exists name Name of the JMS Destination Nr: rb r" r$ r1 zJMS Queue set to be deletedr< Tr; zJMS Queue deletedzJMS Queue doesn't existFr[ r\ )r- r' r rd r r r �destination_absentl s ���rf � datasource�mysql� � c C sv | ddi d�}d| � �}i }i }i }|dkrd|d< n|dkr$d|d< n|d kr-d |d< n|d kr5d |d< i }d dddd�|d< ddddd�|d< ddddd�|d < |d kr_|| d |d < n|| | |d < ||d < ||d < ||d!< ||d"< ||d#< ||d#< | |d$< ||d%< ||d&< | |d'< | |d(< | |d)< | d* |d+< | |d,< ||d-< ||d.< t | d/||�}t |d0||�}|d1 �s)|d1 �s)td2 s�d3|d4< |d5 s�|d5 r�|d6 |d6 d7< |d6 |d6 d8< td2 r�d9|d:< |S d;|d:< |S |d< s�|d< �r|d6 |d6 d7< |d6 |d6 d8< td2 �rd=|d:< |S d>|d:< |S d3|d4< i |d6< d?|d:< |S d@|d4< dA�|d1 |d1 �|d:< |S )Bas Ensures that the JDBC Datasource exists name Name of the datasource description Description of the datasource enabled Is the datasource enabled? defaults to ``true`` restype Resource type, can be ``datasource``, ``xa_datasource``, ``connection_pool_datasource`` or ``driver``, defaults to ``datasource`` vendor SQL Server type, currently supports ``mysql``, ``postgresql`` and ``mssql``, defaults to ``mysql`` sql_url URL of the server in jdbc form sql_user Username for the server sql_password Password for that username min_size Minimum and initial number of connections in the pool, defaults to ``8`` max_size Maximum number of connections that can be created in the pool, defaults to ``32`` resize_quantity Number of connections to be removed when idle_timeout expires, defaults to ``2`` idle_timeout Maximum time a connection can remain idle in the pool, in seconds, defaults to ``300`` wait_timeout Maximum time a caller can wait before timeout, in seconds, defaults to ``60`` non_transactional Return non-transactional connections transaction_isolation Defaults to the JDBC driver default isolation_guaranteed All connections use the same isolation level Nr: zjdbc/rg zjavax.sql.DataSourcer` � xa_datasourcezjavax.sql.XADataSource�connection_pool_datasourcez"javax.sql.ConnectionPoolDataSource�driverzjavax.sql.Driverzcom.mysql.jdbc.Driverz-com.mysql.jdbc.jdbc2.optional.MysqlDataSourcez/com.mysql.jdbc.jdbc2.optional.MysqlXADataSourcez;com.mysql.jdbc.jdbc2.optional.MysqlConnectionPoolDataSource)rm rg rk rl rh zorg.postgresql.Driverz$org.postgresql.ds.PGSimpleDataSourcez org.postgresql.xa.PGXADataSourcez,org.postgresql.ds.PGConnectionPoolDataSourceZ postgresqlz,com.microsoft.sqlserver.jdbc.SQLServerDriverz0com.microsoft.sqlserver.jdbc.SQLServerDataSourcez2com.microsoft.sqlserver.jdbc.SQLServerXADataSourcez>com.microsoft.sqlserver.jdbc.SQLServerConnectionPoolDataSourceZmssqlZdriverClassnameZdatasourceClassname�url�user�passwordra r? rA r@ rB rC rD rE rF rG ZnonTransactionalConnectionsZtransactionIsolationLevelZisIsolationLevelGuaranteed�jdbc_connection_poolZ jdbc_resourcer" r$ Tr; r! r rI rJ z!JDBC Datasource set to be createdr< zJDBC Datasource createdr z!JDBC Datasource set to be updatedzJDBC Datasource updatedz%JDBC Datasource is already up-to-dateFrK rL )r- r? r@ rN �vendorZsql_urlZsql_userZ sql_passwordrO rP rQ rR rS Znon_transactionalZtransaction_isolationZisolation_guaranteedr' r Zres_namerT Zpool_data_propertiesrU Z datasourcesrW rX r r r �jdbc_datasource_present� s� H � � � �� � ��rs c C s� | ddi d�}t | dd|i|�}|d s:td r"|d r"d|d < |S |d r0d |d < d |d < |S d |d < d |d < |S d|d < d�|d �|d < |S )z� Ensures the JDBC Datasource doesn't exists name Name of the datasource both Delete both the pool and the resource, defaults to ``true`` Nr: rq rZ r" r$ r1 z!JDBC Datasource set to be deletedr< Tr; zJDBC Datasource deletedz JDBC Datasource doesn't existFr[ r\ )r- r] r' r rW r r r �jdbc_datasource_absent* s$ � ���rt c K sH dddi d�}|d= z t d | d�}W n- tjy@ } z td r0||d< d|d < |W Y d}~S d |d < |W Y d}~S d}~ww ||d �|d< ||ks�|�|� td s�zt d || d� ||d< d|d < d|d< W |S ty� } z||d< d|d < W Y d}~|S d}~ww d|d < ||d< d|d< |S i |d< d|d < d|d< |S )zf Ensures that the system properties are present properties The system properties r Nr: r- � glassfish.get_system_propertiesr( r$ r r; r& r" )r �kwargsz"glassfish.update_system_propertiesTzSystem properties updatedr< Fz)System properties would have been updatedZcomentz(System properties are already up-to-date)r r) r* r+ r r )r' rv r r r" r r r �system_properties_presentG sJ �� � ���rw c C s dddi d�}z t d |d�}W n/ tjy? } z"td r/d| i|d< d|d < |W Y d}~S d |d < |W Y d}~S d}~ww | |v r�td suzt d | |d� d |d < d|d< W n" tyt } z||d< d|d < W Y d}~n d}~ww d|d < d|d< d| i|d< |S d |d < d|d< |S )zg Ensures that the system property doesn't exists name Name of the system property r Nr: ru r( r$ r% r r; r& r" z"glassfish.delete_system_propertiesTzSystem properties deletedr< Fz)System properties would have been deletedz$System properties are already absentr2 )r- r' r r r" r r r �system_properties_absents s< �� �� �rx )N) r4 r Tr5 r6 r7 r8 r9 Fr FN)TN)r_ r TN)r Trg rh r r r ri rj r7 r8 r9 Fr TN)�__doc__Zsalt.utils.jsonr Zsalt.exceptionsr r) r � ImportErrorr r r r0 r3 rY r^ re rf rs rt rw rx r r r r �<module> sh � ) � ~ � > � ' ,
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings