File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/cache/__pycache__/__init__.cpython-310.pyc
Back
o ;j�/ � @ sl d Z ddlZddlZddlmZ ddlZddlZddlZe� e �Z dd� Z G dd� d�Z G dd � d e �ZdS ) z\ Loader mechanism for caching data, with data expiration, etc. .. versionadded:: 2016.11.0 � N)� OrderedDictc K s& | � dd�r t}nt}|| fi |��S )z� Creates and returns the cache class. If memory caching is enabled by opts MemCache class will be instantiated. If not Cache class will be returned. �memcache_expire_secondsr )�get�MemCache�Cache)�opts�kwargs�cls� r �G/opt/saltstack/salt/lib/python3.10/site-packages/salt/cache/__init__.py�factory s r c @ st e Zd ZdZddd�Zdd� Zedd� �Zd d � Zdd d �Z d d� Z dd� Z dd� Z ddd�Z dd� Zddd�ZdS )r a� Base caching object providing access to the modular cache subsystem. Related configuration options: :param cache: The name of the cache driver to use. This is the name of the python module of the `salt.cache` package. Default is `localfs`. Terminology: Salt cache subsystem is organized as a tree with nodes and leafs like a filesystem. Cache consists of banks. Each bank can contain a number of keys. Each key can contain a dict or any other object serializable with `salt.payload`. I.e. any data object in the cache can be addressed by the path to the bank and the key name: bank: 'minions/alpha' key: 'data' Bank names should be formatted in a way that can be used as a directory structure. If slashes are included in the name, then they refer to a nested structure. Key name is a string identifier of a data container (like a file inside a directory) which will hold the data. Nc K sZ || _ |d u r|�dtjj�| _n|| _|�dtjjd �| _d | _ || _ | j| j d< d S )N�cachedir�cache) r r �saltZsyspathsZ CACHE_DIRr ZconfigZDEFAULT_MASTER_OPTS�driver�_modules�_kwargs)�selfr r r r r r �__init__; s zCache.__init__c C sF t j�| j�| _| j� d�}|| jv r | j| | j�| _d S i | _d S )Nz .init_kwargs)r �loaderr r r r �modulesr �r �funr r r Z __lazy_initF s zCache.__lazy_initc C s | j d u r | �� | j S �N)r �_Cache__lazy_init�r r r r r N s z Cache.modulesc C s< t | d�r| jd ur t | jd�r| j�� d | _d S d S d S )Nr �destroy)�hasattrr r r r r r r T s �z Cache.destroyc K s� |� dd�}| �||�}d}|du rd}n tt�� �| |kr!d}| �||�} | r-|du rU|durGg } |di |��} | D ] } | �|| �� q<n|di |��} | �||| � | S )aI Check cache for the data. If it is there, check to see if it needs to be refreshed. If the data is not there, or it needs to be refreshed, then call the callback function (``fun``) with any given ``**kwargs``. In some cases, the callback function returns a list of objects which need to be processed by a second function. If that is the case, then the second function is passed in as ``loop_fun``. Each item in the return list from the first function will be the only argument for the second function. �expirei�Q FNTr )r �updated�int�time�fetch�append�store) r �bank�keyr Zloop_funr Zexpire_secondsr Z update_cache�data�items�itemr r r r Z s$ �z Cache.cachec C s( | j � d�}| j| |||fi | j��S )a� Store data using the specified module :param bank: The name of the location inside the cache which will hold the key and its associated data. :param key: The name of the key (or file inside a directory) which will hold the data. File extensions should not be provided, as they will be added by the driver itself. :param data: The data which will be stored in the cache. This data should be in a format which can be serialized by msgpack. :raises SaltCacheError: Raises an exception if cache driver detected an error accessing data in the cache backend (auth, permissions, etc). z.store�r r r )r r% r& r' r r r r r$ � s z Cache.storec C �& | j � d�}| j| ||fi | j��S )a� Fetch data using the specified module :param bank: The name of the location inside the cache which will hold the key and its associated data. :param key: The name of the key (or file inside a directory) which will hold the data. File extensions should not be provided, as they will be added by the driver itself. :return: Return a python object fetched from the cache or an empty dict if the given path or key not found. :raises SaltCacheError: Raises an exception if cache driver detected an error accessing data in the cache backend (auth, permissions, etc). z.fetchr* �r r% r& r r r r r" � � z Cache.fetchc C r+ )a� Get the last updated epoch for the specified key :param bank: The name of the location inside the cache which will hold the key and its associated data. :param key: The name of the key (or file inside a directory) which will hold the data. File extensions should not be provided, as they will be added by the driver itself. :return: Return an int epoch time in seconds or None if the object wasn't found in cache. :raises SaltCacheError: Raises an exception if cache driver detected an error accessing data in the cache backend (auth, permissions, etc). z.updatedr* r, r r r r � r- z Cache.updatedc C s( | j � d�}| j| |fd|i| j��S )a� Remove the key from the cache bank with all the key content. If no key is specified remove the entire bank with all keys and sub-banks inside. :param bank: The name of the location inside the cache which will hold the key and its associated data. :param key: The name of the key (or file inside a directory) which will hold the data. File extensions should not be provided, as they will be added by the driver itself. :raises SaltCacheError: Raises an exception if cache driver detected an error accessing data in the cache backend (auth, permissions, etc). z.flushr& r* r, r r r �flush� s z Cache.flushc C s$ | j � d�}| j| |fi | j��S )a Lists entries stored in the specified bank. :param bank: The name of the location inside the cache which will hold the key and its associated data. :return: An iterable object containing all bank entries. Returns an empty iterator if the bank doesn't exists. :raises SaltCacheError: Raises an exception if cache driver detected an error accessing data in the cache backend (auth, permissions, etc). z.listr* )r r% r r r r �list� s z Cache.listc C r+ )a Checks if the specified bank contains the specified key. :param bank: The name of the location inside the cache which will hold the key and its associated data. :param key: The name of the key (or file inside a directory) which will hold the data. File extensions should not be provided, as they will be added by the driver itself. :return: Returns True if the specified key exists in the given bank and False if not. If key is None checks for the bank existense. :raises SaltCacheError: Raises an exception if cache driver detected an error accessing data in the cache backend (auth, permissions, etc). z .containsr* r, r r r �contains� s zCache.containsr )�__name__� __module__� __qualname__�__doc__r r �propertyr r r r$ r" r r. r/ r0 r r r r r s & r c sj e Zd ZdZi Z� fdd�Zedd� �Zdd� Ze dd � �Z � fd d �Z � fd d �Z d� fdd� Z � ZS )r za Short-lived in-memory cache store keeping values on time and/or size (count) basis. c sh t � j|fi |�� |�dd�| _|�dd�| _|�dd�| _|�dd�| _| jr/d| _d| _d | _ d S ) Nr � Zmemcache_max_itemsi Zmemcache_full_cleanupFZmemcache_debugr ) �superr r r �max�cleanup�debug�call�hit�_storage)r r r �� __class__r r r s zMemCache.__init__c C sJ t � � }| j�� D ]}t|�� �D ]\}}|d | |k r!||= q q d S )Nr )r! r' �valuesr/ r( )r r �now�storager& r' r r r Z __cleanup s ��zMemCache.__cleanupc C s, | j � d�}|| jv r| j| | j�S | j S )Nz .storage_id)r r r r r r r �_get_storage_id( s zMemCache._get_storage_idc C s: | j d u r| �� }|tjvrt� tj|< tj| | _ | j S r )r= rC r r' r )r Z storage_idr r r rB / s zMemCache.storagec s� | j r | jd7 _t�� }| j�||fd �}|d urM|d | j |krM| j r>| jd7 _t� d| j| jt| j�| j � ||d< || j||f< |d S t � � ||�}t | j�| j krt| j ret�| j� t | j�| j krt| jjdd� ||g| j||f< |S )N� r z(MemCache stats (call/hit/rate): %s/%s/%sF��last)r: r; r! rB �popr r< �log�floatr7 r" �lenr8 r9 r �_MemCache__cleanup�popitem)r r% r& rA �recordr' r> r r r" 8 s0 � zMemCache.fetchc s| | j �||fd � t� �|||� t| j �| jkr1| jr"t�| j � t| j �| jkr1| j j dd� t � � |g| j ||f< d S )NFrE ) rB rG r7 r$ rJ r8 r9 r rK r rL r! )r r% r& r' r> r r r$ V s zMemCache.storeNc sZ |d u rt | j�D ]\}}||kr| j�||f� q n | j�||fd � t� �||� d S r )�tuplerB rG r7 r. )r r% r& Zbank_Zkey_r> r r r. ` s ��zMemCache.flushr )r1 r2 r3 r4 r' r � classmethodrK rC r5 rB r" r$ r. � __classcell__r r r> r r s r )r4 �loggingr! � collectionsr Z salt.configr Z salt.loaderZ salt.syspaths� getLoggerr1 rH r r r r r r r �<module> s l
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings