🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-07 07:04:11 | PHP 8.2.32
📂
/ (Root)
/
usr
/
lib
/
python3.6
/
site-packages
/
sos
/
collector
/
clusters
/
__pycache__
📍 /usr/lib/python3.6/site-packages/sos/collector/clusters/__pycache__
🔄 Refresh
✏️
Editing: juju.cpython-36.pyc
Read Only
3 ܓ�i�! � @ sb d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dd�Zdd� Z G d d � d e�Z dS ) � N)�Cluster)�sos_parse_version)�sos_get_command_outputc C s | sg S dd� | j d�D �S )z Parse comma separated string.c S s g | ] }|j � �qS � )�strip)�.0�stringr r �/usr/lib/python3.6/juju.py� <listcomp> s z(_parse_option_string.<locals>.<listcomp>�,)�split)Zstringsr r r �_parse_option_string s r c C s G dd� d�}|| �S )aR Helper function to get Index. The reason why we need Index defined in function is because currently the collector.__init__ will load all the classes in this module and also Index. This will cause bug because it think Index is Cluster type. Also We don't want to provide a customized filter to remove Index class. c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) z_get_index.<locals>.Indexz�Index structure to help parse juju status output. Attributes apps, units and machines are dict which key is the app/unit/machine name and the value is list of targets which format are {model_name}:{machine_id}. c S s( || _ i | _i | _i | _tjd�| _d S )NZsos)� model_name�apps�units�machines�loggingZ getLogger�ui_log)�selfr r r r �__init__. s z"_get_index.<locals>.Index.__init__c S s� x�|d j � D ]r\}}g }|jdi �}xN|j � D ]B\}}|d }| j� d|� �} | g| j|< | g| j|< |j| � q0W || j|< qW dS )z Adds principal units to index.� applicationsr �machine�:N)�items�getr r r �appendr ) r � juju_status�app�app_info�nodesr Zunit� unit_infor �noder r r �add_principals5 s z(_get_index.<locals>.Index.add_principalsc S s �x|d j � D ]�\}}|jdg �}x�|D ]�}| jj|�sP| jjd|� d�� q*| j| j| j| � d|d | kr�| jjd|� d�� q*|d | d }x`|j � D ]T\}}| j� d|d � �} x6|jd i �j � D ]"\} }| j|d �r�| g| j| < q�W q�W q*W qW d S ) z�Add subordinates to index. Since subordinates does not have units they need to be manually added. r zsubordinate-tozPrincipal charm z is missingr z is missing unitsr r Z subordinates�/N) r r r r Zwarning�extendr � startswithr ) r r r r Zsubordinate_to�parentr �_r r! Zsub_keyr r r �add_subordinatesC s& z*_get_index.<locals>.Index.add_subordinatesc S s6 x0|d j � D ] }| j� d|� �}|g| j|< qW dS )z�Add machines to index. If model does not have any applications it needs to be manually added. r r N)�keysr r )r r r r! r r r � add_machinesd s z&_get_index.<locals>.Index.add_machinesN)�__name__� __module__� __qualname__�__doc__r r" r( r* r r r r �Index% s !r/ r )r r/ r r r � _get_index s Ir0 c @ sd e Zd ZdZd ZdZd d d d gZd d � Zdd� Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� Zd S )!�jujua! The juju cluster profile is intended to be used on juju managed clouds. It"s assumed that `juju` is installed on the machine where `sos` is called, and that the juju user has superuser privilege to the current controller. By default, the sos reports will be collected from all the applications in the current model. If necessary, you can filter the nodes by models / applications / units / machines with cluster options. Example: sos collect --cluster-type juju -c "juju.models=sos" -c "juju.apps=a,b,c" zJuju Managed Cloudsr � �1Filter node list by apps (comma separated regex).r �3Filter node list by units (comma separated string).�models�4Filter node list by models (comma separated string).r �6Filter node list by machines (comma separated string).c C s t jdd|dt jd�S )z#Remove leading characters before {.z (^[^{]*)(.*)z\2r )�count�flags)�re�sub� MULTILINE)r �outputr r r �_cleanup_juju_output� s zjuju._cleanup_juju_outputc C s6 | j |�}t|d�}|j|� |j|� |j|� |S )z�Parse juju status output and return target dict. Here are couple helper functions to parse the juju principals units, subordinate units and machines. )r )�_execute_juju_statusr0 r" r( r* )r r r �indexr r r �_get_model_info� s zjuju._get_model_infoc C s t d�}|d S )zGrab the version of jujuz juju versionr= )r )r �resr r r �_get_juju_version� s zjuju._get_juju_versionc C s� |rd|� �nd}d}| j � }t|�td�kr6|d7 }| j� d|� d|� �}| j|�}|d d ksztd |� d |d � ���| j|d �}d }tj|�}|S ) Nz-m r2 z --format json�3z --no-colorz status � Zstatusr �'z' returned error: r= )rC r �cmdZexec_primary_cmd� Exceptionr> �json�loads) r r Z model_optionZ format_optionZ juju_versionZ status_cmdrB Zjuju_json_outputr r r r r? � s zjuju._execute_juju_statusc C sN t � }xB|D ]:}x4t||�j� D ]"\}}tj||�r |j|p>g � q W q W |S )zFilter with regex match.)�set�getattrr r: �match�update)r �key�patterns� model_infor �pattern�param�valuer r r �_filter_by_pattern� s zjuju._filter_by_patternc C sJ t � }x>|D ]6}x0t||�j� D ] \}}||kr |j|p:g � q W q W |S )zFilter with fixed match.)rK rL r rN )r rO rP rQ r rR rS rT r r r �_filter_by_fixed� s zjuju._filter_by_fixedc C s dS )z'Dynamically change transport to 'juju'.r1 r )r r r r �set_transport_type� s zjuju.set_transport_typec C s� t | jd��}t | jd��}t | jd��}t | jd��}|||d�}t|j� � r\| r\g S |sfdg}t� }x\|D ]T}| j|�}xD|j� D ]8\} } | dkr�| j| | |�} n| j| | |�} |j | � q�W qrW t |�S )z+Get the machine numbers from `juju status`.r5 r r r )r r r r2 ) r Z get_option�any�valuesrK rA r rU rV rN �list) r r5 r r r �filtersr ZmodelrQ rO ZresourceZ_nodesr r r � get_nodes� s$ zjuju.get_nodesN)r r2 r3 )r r2 r4 )r5 r2 r6 )r r2 r7 )r+ r, r- r. rG Z cluster_nameZ option_listr> rA rC r? rU rV rW r\ r r r r r1 q s" r1 )N) r rI r: Zsos.collector.clustersr Z sos.utilitiesr r r r0 r1 r r r r �<module> s V
💾 Save Changes
❌ Cancel