File: //lib/python3/dist-packages/sos/report/plugins/__pycache__/kafka.cpython-312.pyc
�
O6uf[ � �4 � d dl Z d dlmZmZ G d� dee� Zy)� N)�Plugin� UbuntuPluginc �: � e Zd ZdZdZdZdZdZdZdZ d� Z
d � Z d
� Z y ) �Kafkaz�
This plugin collects log and configuration files, and also basic
installation information (e.g., `snap info`) for Apache Kafka.
zApache Kafka plugin�kafka)�services)�
charmed-kafka)r Fc �b � | j j j d� }|r|d dk( S y)Nr � pkg_manager�snapF)�policy�package_manager� pkg_by_name)�self� kafka_pkgs �:/usr/lib/python3/dist-packages/sos/report/plugins/kafka.py�_is_snap_installedzKafka._is_snap_installed s2 � ��K�K�/�/�;�;�O�L� � � �]�+�v�5� 5�� c �� � | j � | _ | j d� rdnd}| j r| j d� d}d}nd}d}| j ||z |g� y ) N�all_logsz*.log*z*.logzsnap info charmed-kafkaz-/var/snap/charmed-kafka/common/var/log/kafka/�*/var/snap/charmed-kafka/current/etc/kafka/z/usr/local/kafka/logs/�/usr/local/kafka/config/)r �is_snap�
get_option�add_cmd_output�
add_copy_spec)r �log_file_pattern�log_path� config_paths r �setupz Kafka.setup" sn � ��.�.�0�� �'+���z�'B�8��� �<�<� � � � 9� :�F�H�F�K�/�H�4�K� ��� �'� '� �
� r c � � ddg}| j rdnd}ddj |� � d�}t j |� D ]> \ }}}|D ]3 }| j t j
j ||� |d� �5 �@ y ) N�password�usernamer r z(^\s*(�|z
)\s*=\s*)(.*)z \1*********)r �join�os�walk�do_path_regex_sub�path)r � protect_keysr �regexp�root�_�files�files r �postproczKafka.postproc4 s� � �"�J�0� � �|�|�
9�+� � �3�8�8�L�1�2�-�@�� �g�g�k� 2� ?�N�D�!�U� �
?���&�&�r�w�w�|�|�D�$�'?�'-�~�?�
?� ?r N)
�__name__�
__module__� __qualname__�__doc__�
short_desc� plugin_name�profiles�packagesr r r r r0 � r r r r s6 � ��
'�J��K� �H�!�H��H��G�� �$?r r )r& �sos.report.pluginsr r r r9 r r �<module>r; s ��
� 3�4?�F�L� 4?r