/usr/lib/python3.9/site-packages/glances/plugins/__pycache__
a ���c�| � @ s$ d Z ddlZddlZddlZddlmZ ddlmZmZm Z m Z ddl m Z ddl mZ ddlmZmZ ddlmZ z ddlZdd lmZmZ W n8 ey� Z z d Ze � d � e�� W Y dZ[ndZ[0 0 d Zd ddd�gZ g d�Z ddddddd�Z G dd� de�Z!G dd � d ej"�Z#d d � Z$dS ) zDocker plugin.� N)�deepcopy)�iterkeys� itervalues� nativestr� pretty_date)�logger)� GlancesPlugin)� sort_stats�glances_processes)�getTimeSinceLastUpdate)�parser�tzTz=Error loading Docker deps Lib. Docker plugin is disabled ({})F� cpu_percentz Container CPU consumption in %�%)�name� descriptionZy_unit)�cpu�io�memory�networkzdisk IOzCPU consumptionzmemory consumptionZuptimezcontainer name�None)� io_countersr � memory_usage� cpu_timesr Nc s� e Zd ZdZd%� fdd� Z� fdd�Zdd� Zd d � Zd d � Zd d� Z e j e j dd� ��Z dd� Zdd� Zdd� Zdd� Zdd� Zdd � Z� fd d �Zd&d d �Zd!d"� Zd#d$� Z� ZS )'�Pluginz\Glances Docker plugin. stats is a dict: {'version': {...}, 'containers': [{}, {}]} Nc sb t t| �j||td� || _|| _d| _| �� | _i | _ i | _ i | _ d| _ | � � | j�d� dS )zInit the plugin.)�args�config�items_history_listTNr )�superr �__init__r r r Z display_curse�connect� docker_client� thread_list� network_old�io_old�sort_key�updateZ refresh_timer�set)�selfr r �� __class__� �B/usr/lib/python3.9/site-packages/glances/plugins/glances_docker.pyr N s zPlugin.__init__c s* t | j�D ] }|�� q tt| ��� dS )z+Overwrite the exit method to close threads.N)r r" �stopr r �exit)r( �tr) r+ r, r. t s z Plugin.exitc C s dS )zReturn the key of the list.r r+ �r( r+ r+ r, �get_key{ s zPlugin.get_keyc C sn zt | jd �}W n8 tyJ } z t�d�|�� g }W Y d}~n d}~0 0 |D ]}tD ]}|�|� qXqP|S )z~Overwrite the default export method. - Only exports containers - The key is the first container name � containersz&docker plugin - Docker export error {}N)r �stats�KeyErrorr �debug�format�export_exclude_list�pop)r( �ret�e� container�ir+ r+ r, � get_export s zPlugin.get_exportc C sJ z t �� }W n8 tyD } z t�d�|�� d}W Y d}~n d}~0 0 |S )z Connect to the Docker server.z.docker plugin - Can not connect to Docker ({})N)�dockerZfrom_env� Exceptionr �errorr6 )r( r9 r: r+ r+ r, r � s zPlugin.connectc C s. | � d�}t|�dkrdS |d �� dkS dS )z�Return the all tag of the Glances/Docker configuration file. # By default, Glances only display running containers # Set the following key to True to display all containers all=True �allr F�trueN)Zget_conf_value�len�lower)r( Zall_tagr+ r+ r, �_all_tag� s zPlugin._all_tagc C sz | � � }ts| jdu r | jS | jdk�rXz| j�� |d< W nZ ty� } zBt�d� | j |�� d| jv rp| jd= g | jd< | jW Y d}~S d}~0 0 z | jj j | � � d�p�g }W nJ t� y� } z0t�d� | j |�� g | jd< | jW Y d}~S d}~0 0 |D ]N}|j| jv�rt�d� | j |jdd � �� t|�}|| j|j< |�� �qtt| j��td d � |D �� }|D ]8}t�d � | j |dd � �� | j| �� | j|= �qvg |d< |D �]�}| �t|j���sؐq�i }| �� |d < t|j�|d< |j|d< |jj|d< |j d d |d< g |d< |j d � dd��rV|d � |j d � dg �� |j d � dd��r�|d � |j d � dg �� |d �s�d|d< |d dv �r�| � |j| j|j j�|d< |d � dd�|d< | � |j| j|j j�|d< |d � d d�|d < |d � d d�du�r4|d |d d 8 < | �!|j| j|j j�|d < |d � d d�|d!< |d � d"d�|d#< | �"|j| j|j j�|d$< |d$ � d%d�|d&< |d$ � d'd�|d(< t#t$�%|j d d) ��&t'�(� �j)dd*��|d+< nXi |d< d|d< i |d< d|d,< i |d < d|d!< d|d#< i |d$< d|d&< d|d(< d|d+< |d �*|� �q�n | jd-k�rdt+|�\| _,| _| jS ).z+Update Docker stats using the input method.N�local�versionz*{} plugin - Cannot get Docker version ({})r2 )rA z+{} plugin - Cannot get containers list ({})z*{} plugin - Create thread for container {}� c S s g | ] }|j �qS r+ )�id)�.0�cr+ r+ r, � <listcomp>� � z!Plugin.update.<locals>.<listcomp>z,{} plugin - Stop thread for old container {}�keyr ZIdZImage�State�Status�CommandZConfigZ EntrypointZCmd)�runningZpausedr �totalr r �usager �cacher �iorZio_r�iowZio_wr �rxZ network_rx�txZ network_txZ StartedAt)Ztzinfo�Uptime�memory_percentZsnmp)-Zget_init_value�import_error_tagr! r3 Z input_methodrG r? r r@ r6 Z plugin_namer2 �listrE rI r" r5 �ThreadDockerGrabber�startr' r r- Z is_displayr r r1 Zimage�tags�attrs�get�extend�get_docker_cpu�get_docker_memory� get_docker_io�get_docker_networkr r �parseZ astimezoner Ztzlocal�replace�append�sort_docker_statsr% ) r( r3 r: r2 r; r/ Zabsent_containers� container_idZcontainer_statsr+ r+ r, r& � s� � � ���� z Plugin.updatec C sJ ddi}z||d d |d d d d�}|d d |d d d d�}|d � d d �|d < |d d u r�t|d d d pzg �|d < W n@ ty� } z(t�d �||�� t�|� W Y d }~n�d }~0 0 z<|d |d }|d |d }|| |d d |d< W nB t�yD } z(t�d�||�� t�|� W Y d }~n d }~0 0 |S )z�Return the container CPU usage. Input: id is the full container id all_stats is the output of the stats method of the Docker API Output: a dict {'total': 1.49} rS g � cpu_statsZsystem_cpu_usageZ cpu_usageZ total_usage)�systemrS Z precpu_statsZ online_cpusNZnb_coreZ percpu_usagez;docker plugin - Cannot grab CPU usage for container {} ({})rn g Y@z>docker plugin - Cannot compute CPU usage for container {} ({}))rb rC r4 r r5 r6 � TypeError) r( rl � all_statsrm r Zprecpur: Z cpu_deltaZsystem_cpu_deltar+ r+ r, rd C s, � � zPlugin.get_docker_cpuc C s� i }z�|d d |d< |d d |d< d|d d v rL|d d d |d< n.d|d d v rr|d d d |d< nd|d< |d d � dd�|d< |d � d d�|d < W nD ttfy� } z(t�d �||�� t�|� W Y d}~n d}~0 0 |S ) z�Return the container MEMORY. Input: id is the full container id all_stats is the output of the stats method of the Docker API Output: a dict {'rss': 1015808, 'cache': 356352, 'usage': ..., 'max_usage': ...} � memory_statsrT �limitZrssr3 Z total_rssNrU Z max_usagez;docker plugin - Cannot grab MEM usage for container {} ({}))rb r4 ro r r5 r6 )r( rl rp rq r: r+ r+ r, re l s zPlugin.get_docker_memoryc C s i }z |d }W nD t yT } z,t�d�||�� t�|� |W Y d}~S d}~0 0 z$|d d |d< |d d |d< W n@ t y� } z(t�d �||�� t�|� W Y d}~nfd}~0 0 td �|��|d < || jv �r|d | j| d |d < |d | j| d |d < || j|< |S )az Return the container network usage using the Docker API (v1.0 or higher). Input: id is the full container id Output: a dict {'time_since_update': 3000, 'rx': 10, 'tx': 65}. with: time_since_update: number of seconds elapsed between the latest grab rx: Number of bytes received tx: Number of bytes transmitted Znetworksz;docker plugin - Cannot grab NET usage for container {} ({})NZeth0Zrx_bytesZ cumulative_rxZtx_bytesZ cumulative_txzIdocker plugin - Cannot grab network interface usage for container {} ({})z docker_net_{}�time_since_updaterX rY )r4 r r5 r6 r r# )r( rl rp Z network_newZ net_statsr: r+ r+ r, rg � s* � zPlugin.get_docker_networkc C s6 i }z |d }W nD t yT } z,t�d�||�� t�|� |W Y d}~S d}~0 0 z@|d }dd� |D �d d |d < d d� |D �d d |d < W n> ttt tfy� } z t�d�||�� W Y d}~nfd}~0 0 td �|��|d < || jv �r(|d | j| d |d< |d | j| d |d< || j|< |S )aq Return the container IO usage using the Docker API (v1.0 or higher). Input: id is the full container id Output: a dict {'time_since_update': 3000, 'ior': 10, 'iow': 65}. with: time_since_update: number of seconds elapsed between the latest grab ior: Number of bytes read iow: Number of bytes written Z blkio_statsz@docker plugin - Cannot grab block IO usage for container {} ({})N�io_service_bytes_recursivec S s g | ]}|d � � dkr|�qS )�op�read�rD �rJ r< r+ r+ r, rL � rM z(Plugin.get_docker_io.<locals>.<listcomp>r �valueZcumulative_iorc S s g | ]}|d � � dkr|�qS )ru �writerw rx r+ r+ r, rL � rM Zcumulative_iowz docker_io_{}rs rV rW ) r4 r r5 r6 ro � IndexError�AttributeErrorr r$ )r( rl rp Zio_newZio_statsr: rt r+ r+ r, rf � s& ( zPlugin.get_docker_ioc C s t �t jd �S )z:Return the user ticks by reading the environment variable.� SC_CLK_TCK)�os�sysconf� sysconf_namesr0 r+ r+ r, �get_user_ticks� s zPlugin.get_user_ticksc C s | j d S )zZReturn stats for the action. Docker will return self.stats['containers'] r2 )r3 r0 r+ r+ r, �get_stats_action� s zPlugin.get_stats_actionc s@ t t| ��� d| jvr dS | jd D �]}i i d�| j|| �� < d|v r�d|d v r�| j|d d |d d |d d�}|d kr�| j|d d dd �}|| j|| �� d d < d |v r&d |d v r&| j|d d |d d |d d |d d�}|d k�r | j|d d |d d dd�}|| j|| �� d d < q&dS )zUpdate stats views.r2 F)r �memr rS r Z_cpu)�header� action_key�DEFAULT)r� � decorationr rT rr Z_mem)�maximumr� r� r� )r� r� T)r r � update_viewsr3 Zviewsr1 Z get_alert)r( r< Zalertr) r+ r, r� � s$ $$� zPlugin.update_viewsc C s� g }| j r.d| j vs.t| j d �dks.| �� r2|S d�d�}|�| �|d�� d�t| j d ��}|�| �|�� d�t| j �}|�| �|�� |�| �� � |�| �� � t | j dur�| j j d d d d �nd tt | j d d d� d�d ��}djd|d�}|�| �|| jdk�rdnd�� d�d�}|�| �|�� d�d�}|�| �|�� d�d�}|�| �|| jdk�rvdnd�� d �d �}|�| �|| jd k�r�dnd�� d �d �}|�| �|�� d �d!�}|�| �|�� d"�d#�}|�| �|�� d �d$�}|�| �|�� d"�d%�}|�| �|�� d&�d'�}|�| �|�� | j d D �]�}|�| �� � |�| �| j ||d(��� | �|d �}d�|d dd)� �}|�| �||�� |d �r�d�|d �}n d�d*�}|�| �||�� zd+�|d, d- �}W n t�y d�d*�}Y n0 |�| �|| j|d d,d.d/��� z d �| �|d0 d1 ��}W n t�y| d �d*�}Y n0 |�| �|| j|d d2d.d/��� z d �| �|d0 d3 ��}W n t�y� d �d*�}Y n0 |�| �|�� d4}z4| �t|d5 d6 |d5 d7 ��| } d �| �}W n t�yB d �d*�}Y n0 |�| �|�� z4| �t|d5 d8 |d5 d7 ��| } d"�| �}W n t�y� d"�d*�}Y n0 |�| �|�� |j�r�d9} d:}nd;} d<}z8| �t|d= d> |d= d7 | ��| } d �| �}W n t�y( d �d*�}Y n0 |�| �|�� z8| �t|d= d? |d= d7 | ��| } d"�| �}W n t�y� d"�d*�}Y n0 |�| �|�� |d' du�r�d�d@�|d' ��}n d�d*�}|�| j|dAdB�� �qP|S )Cz2Return the dict to display in the curse interface.r2 r z{}Z CONTAINERSZTITLEz {}z sorted by {}Nr> Z max_name_size� )�defaultc S s t | d �S )Nr )rC )�xr+ r+ r, �<lambda>0 rM z"Plugin.msg_curse.<locals>.<lambda>)rN r � {:{width}}�Name��widthZSORTr� z{:>10}rP rZ z{:>6}zCPU%r z{:>7}ZMEMr z/{:<7}�MAXzIOR/sz {:<7}zIOW/szRx/szTx/sz {:8}rQ )r; � max_width� �_z{:>6.1f}r rS r� )�itemrN �optionr rT r� rr �Br rV rs rW � � � �br rX rY � T)Z splittable)r3 rC Z is_disabledr6 rj Zcurse_add_line�sort_for_humanr% Zcurse_new_line�minr Z get_int_value�max� _msg_name�container_alertr4 Z get_viewsZ auto_unit�intZbyte�join) r( r r� r9 �msgZname_max_widthr; �statusZunitry Zto_bitr+ r+ r, � msg_curse s� * �" " " " " && ��� ��� zPlugin.msg_cursec C s |d d|� }dj ||d�S )zBuild the container name.r Nr� r� )r6 )r( r; r� r r+ r+ r, r� � s zPlugin._msg_namec C s, |dkr dS |dkrdS |dkr$dS dS dS ) z Analyse the container status.rR ZOKZexitedZWARNINGZdeadZCRITICALZCAREFULNr+ )r( r� r+ r+ r, r� � s zPlugin.container_alert)NN)NN)�__name__� __module__� __qualname__�__doc__r r. r1 r= r rE r Z_check_decoratorZ_log_result_decoratorr& rd re rg rf r� r� r� r� r� r� � __classcell__r+ r+ r) r, r H s, & ) /0 " r c sT e Zd ZdZ� fdd�Zdd� Zedd� �Zejdd� �Zdd d �Z d d � Z � Z S )r^ zD Specific thread to grab docker stats. stats is a dict c sJ t t| ��� t�� | _|| _|jdd�| _i | _ t � d� | jj �� dS )zLInit the class. container: instance of Docker-py Container T)�decodez.docker plugin - Create thread for container {}N)r r^ r � threading�Event�_stopper� _containerr3 � _stats_stream�_statsr r5 r6 r )r( r; r) r+ r, r � s z ThreadDockerGrabber.__init__c C sn z,| j D ] }|| _t�d� | �� r q*qW n< tyh } z$t�d�|�� | � � W Y d}~n d}~0 0 dS )z_Grab the stats. Infinite loop, should be stopped by calling the stop() method g�������?z0docker plugin - Exception thrown during run ({})N) r� r� �time�sleep�stoppedr? r r5 r6 r- )r( r< r: r+ r+ r, �run� s zThreadDockerGrabber.runc C s | j S )z Stats getter.�r� r0 r+ r+ r, r3 � s zThreadDockerGrabber.statsc C s || _ dS )z Stats setter.Nr� )r( ry r+ r+ r, r3 � s Nc C s" t �d�| jj�� | j�� dS )zStop the thread.z-docker plugin - Close thread for container {}N)r r5 r6 r� r r� r' )r( �timeoutr+ r+ r, r- � s zThreadDockerGrabber.stopc C s | j �� S )z%Return True is the thread is stopped.)r� �is_setr0 r+ r+ r, r� � s zThreadDockerGrabber.stopped)N) r� r� r� r� r r� �propertyr3 �setterr- r� r� r+ r+ r) r, r^ � s r^ c C sJ t j}d}|dkr d}d}n |dv r(d}t| d ||t jdkd� || fS )Nr r[ r )�usernamer r r2 r )Z sorted_byZsorted_by_secondary�reverse)r r% �sort_stats_processes)r3 Zsort_byZsort_by_secondaryr+ r+ r, rk � s � rk )%r� r~ r� r� �copyr Zglances.compatr r r r Zglances.loggerr Z glances.plugins.glances_pluginr Zglances.processesr r� r Z glances.timerr r> Zdateutilr r r? r: r\ Zwarningr6 r r7 r� r �Threadr^ rk r+ r+ r+ r, �<module> s@ &� k9
.
Edit
..
Edit
__init__.cpython-39.opt-1.pyc
Edit
__init__.cpython-39.pyc
Edit
glances_alert.cpython-39.opt-1.pyc
Edit
glances_alert.cpython-39.pyc
Edit
glances_amps.cpython-39.opt-1.pyc
Edit
glances_amps.cpython-39.pyc
Edit
glances_cloud.cpython-39.opt-1.pyc
Edit
glances_cloud.cpython-39.pyc
Edit
glances_connections.cpython-39.opt-1.pyc
Edit
glances_connections.cpython-39.pyc
Edit
glances_core.cpython-39.opt-1.pyc
Edit
glances_core.cpython-39.pyc
Edit
glances_cpu.cpython-39.opt-1.pyc
Edit
glances_cpu.cpython-39.pyc
Edit
glances_diskio.cpython-39.opt-1.pyc
Edit
glances_diskio.cpython-39.pyc
Edit
glances_docker.cpython-39.opt-1.pyc
Edit
glances_docker.cpython-39.pyc
Edit
glances_folders.cpython-39.opt-1.pyc
Edit
glances_folders.cpython-39.pyc
Edit
glances_fs.cpython-39.opt-1.pyc
Edit
glances_fs.cpython-39.pyc
Edit
glances_gpu.cpython-39.opt-1.pyc
Edit
glances_gpu.cpython-39.pyc
Edit
glances_help.cpython-39.opt-1.pyc
Edit
glances_help.cpython-39.pyc
Edit
glances_ip.cpython-39.opt-1.pyc
Edit
glances_ip.cpython-39.pyc
Edit
glances_irq.cpython-39.opt-1.pyc
Edit
glances_irq.cpython-39.pyc
Edit
glances_load.cpython-39.opt-1.pyc
Edit
glances_load.cpython-39.pyc
Edit
glances_mem.cpython-39.opt-1.pyc
Edit
glances_mem.cpython-39.pyc
Edit
glances_memswap.cpython-39.opt-1.pyc
Edit
glances_memswap.cpython-39.pyc
Edit
glances_network.cpython-39.opt-1.pyc
Edit
glances_network.cpython-39.pyc
Edit
glances_now.cpython-39.opt-1.pyc
Edit
glances_now.cpython-39.pyc
Edit
glances_percpu.cpython-39.opt-1.pyc
Edit
glances_percpu.cpython-39.pyc
Edit
glances_plugin.cpython-39.opt-1.pyc
Edit
glances_plugin.cpython-39.pyc
Edit
glances_ports.cpython-39.opt-1.pyc
Edit
glances_ports.cpython-39.pyc
Edit
glances_processcount.cpython-39.opt-1.pyc
Edit
glances_processcount.cpython-39.pyc
Edit
glances_processlist.cpython-39.opt-1.pyc
Edit
glances_processlist.cpython-39.pyc
Edit
glances_psutilversion.cpython-39.opt-1.pyc
Edit
glances_psutilversion.cpython-39.pyc
Edit
glances_quicklook.cpython-39.opt-1.pyc
Edit
glances_quicklook.cpython-39.pyc
Edit
glances_raid.cpython-39.opt-1.pyc
Edit
glances_raid.cpython-39.pyc
Edit
glances_sensors.cpython-39.opt-1.pyc
Edit
glances_sensors.cpython-39.pyc
Edit
glances_smart.cpython-39.opt-1.pyc
Edit
glances_smart.cpython-39.pyc
Edit
glances_system.cpython-39.opt-1.pyc
Edit
glances_system.cpython-39.pyc
Edit
glances_uptime.cpython-39.opt-1.pyc
Edit
glances_uptime.cpython-39.pyc
Edit
glances_wifi.cpython-39.opt-1.pyc
Edit
glances_wifi.cpython-39.pyc
Edit