⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.157
Server IP:
97.74.87.16
Server:
Linux 16.87.74.97.host.secureserver.net 5.14.0-503.38.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Apr 18 08:52:10 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.2.28
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
var
/
opt
/
nydus
/
ops
/
primordial
/
__pycache__
/
View File Name :
zkconfig.cpython-39.pyc
a ���gw � @ s� d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlm Z m Z m Z d dl m Z d dlmZ d dlmZ G d d � d e�ZdS ) � N)�deque)�Any)� KazooClient)�ConnectionLoss� NoNodeError�ZookeeperError)�KazooTimeoutError)�Config)� retry_thisc @ s� e Zd ZdZdZe�d�Zedd�dd�Z dd � Z d d � Z e e eejeefd �d d� �Zdd� Zdd� Zdeeed�dd�ZdS )�ZKConfigzFConfig class that loads configuration options from a ZooKeeper clusterz/configz\s*(\S+?)\s*=\s*(\S+)\s*N)�hosts�returnc C s t |dd�| _i | _| �� d S )NT)r Z read_only)r �_client�_config� load_config)�selfr � r �D/opt/nydus/tmp/pip-target-mke_irhy/lib/python/primordial/zkconfig.py�__init__ s zZKConfig.__init__c C s | j �� | j S )z� This turns this class/object into a context manager for connections to the zookeeper cluster. This starts up the connection and returns the client as the resource being managed. )r �start)r r r r � __enter__ s zZKConfig.__enter__c C s0 z| j �� | j �� W n ty* Y n0 dS )ze This method takes care of releasing the client connection to the zookeeper cluster. N)r �stop�close� Exception)r Z _exc_typeZ_exc_valZ_exc_tbr r r �__exit__& s zZKConfig.__exit__)Z on_ex_classesc C sL | �4}| � |�D ]}| j�| �||�� qW d � n1 s>0 Y dS )z� Load HFS config data including config at the various namespaces and flatten it out into a dict representation. N)� enumerater �update�get_config_at_path)r � zk_client�pathr r r r 1 s zZKConfig.load_configc c sJ t | jg�}|rF|�� }|V |�|�D ]}d�||�}|�|� q(q dS )z� Generate all child paths, starting at a particular path. The starting path is also included in this enumeration. z{}/{}N)r �ROOT�popleftZ get_children�format�append)r r Zpaths_to_traverser �childZ child_pathr r r r < s zZKConfig.enumeratec C sv i }|� d�dd� }|�|�\}}|�d�}|� d�D ]8}| j�|�} | r8| �� \} } d�|| g �} | || < q8|S )a, Get the data (which is interpreted as config uploaded to that path/namespace) at a particular zookeeper path. Parse out the data looking for lines that look like key=value. Generate a dict out of this normalizing the key appropriately. Finally return back this dict. �/� Nzutf-8� �.)�split�get�decode� CONFIG_LINE�match�groups�join) r r r �configZ path_sectionsZzk_valueZ_zk_statZ stored_config�liner- �k�vZ config_keyr r r r K s zZKConfig.get_config_at_path)�key�defaultr c C s | j �||�S )z� Get the config option as a string :param key: config option name :param default: default value if no value exists in the config :return: option value )r r* )r r4 r5 r r r r* c s z ZKConfig.get)N)�__name__� __module__� __qualname__�__doc__r �re�compiler, �strr r r r r r �socket�errorr r r r r r r* r r r r r s � r )r: r= � collectionsr �typingr Z kazoo.clientr Zkazoo.exceptionsr r r Zkazoo.handlers.threadingr Zprimordial.configr Zprimordial.utilsr r r r r r �<module> s