/opt/imunify360/venv/lib/python3.11/site-packages/nats/js/__pycache__
� 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<