o i@sddlmZddlmZmZmZmZeGdddeZeGdddeZeGdddeZ eGd d d eZ eGd d d eZ eGd ddeZ GdddeeZ dS))Sequence)AnyProtocol SupportsFloatruntime_checkablec @seZdZdZdddededBdeeefdBfddZdddededBdeeeefdBe dBffd d Z ddd ded eeefdedBd e dBddf ddZ dddededBde fddZdddeededBdeeeefdBfddZdddeededBdeeeeefdBe dBffddZddd deedeeeefdedBd ee dBdBddf ddZdddeededBdefddZdS)AsyncKeyValueProtocolzQA subset of KV operations: get/put/delete and TTL variants, including bulk calls.N) collectionkeyrreturncdS)ayRetrieve a value by key from the specified collection. Args: key: The key to retrieve the value from. collection: The collection to retrieve the value from. If no collection is provided, it will use the default collection. Returns: The value associated with the key. If the key is not found, None will be returned. Nselfr rr r g/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/key_value/aio/protocols/key_value.pyget szAsyncKeyValueProtocol.getcr )aRetrieve the value and TTL information for a key-value pair from the specified collection. Args: key: The key to retrieve the TTL information from. collection: The collection to retrieve the TTL information from. If no collection is provided, it will use the default collection. Returns: The value and TTL information for the key. If the key is not found, (None, None) will be returned. Nr r r r rttl zAsyncKeyValueProtocol.ttl)rrvaluercr )a Store a key-value pair in the specified collection with optional TTL. Args: key: The key to store the value in. value: The value to store. collection: The collection to store the value in. If no collection is provided, it will use the default collection. ttl: The optional time-to-live (expiry duration) in seconds for the key-value pair. Defaults to no TTL. Note: The backend store will convert the provided format to its own internal format. Nr )rr rrrr r rput' zAsyncKeyValueProtocol.putcr )aDelete a key-value pair from the specified collection. Args: key: The key to delete the value from. collection: The collection to delete the value from. If no collection is provided, it will use the default collection. Nr r r r rdelete3zAsyncKeyValueProtocol.deletekeyscr )aRetrieve multiple values by key from the specified collection. Args: keys: The keys to retrieve the values from. collection: The collection to retrieve keys from. If no collection is provided, it will use the default collection. Returns: A list of values for the keys. Each value is either a dict or None if the key is not found. Nr rrrr r rget_many<rzAsyncKeyValueProtocol.get_manycr )aRetrieve multiple values and TTL information by key from the specified collection. Args: keys: The keys to retrieve the values and TTL information from. collection: The collection to retrieve keys from. If no collection is provided, it will use the default collection. Returns: A list of tuples containing (value, ttl) for each key. Each tuple contains either (dict, float) or (None, None) if the key is not found. Nr rr r rttl_manyHrzAsyncKeyValueProtocol.ttl_manyvaluescr )aStore multiple key-value pairs in the specified collection. Args: keys: The keys to store the values in. values: The values to store. collection: The collection to store keys in. If no collection is provided, it will use the default collection. ttl: The optional time-to-live (expiry duration) in seconds for the key-value pairs. Defaults to no TTL. Note: The backend store will convert the provided format to its own internal format. Nr )rrrrrr r rput_manyUszAsyncKeyValueProtocol.put_manycr )aDDelete multiple key-value pairs from the specified collection. Args: keys: The keys to delete the values from. collection: The collection to delete keys from. If no collection is provided, it will use the default collection. Returns: The number of keys deleted. Nr rr r r delete_manyhrz!AsyncKeyValueProtocol.delete_many)__name__ __module__ __qualname____doc__strdictrrtuplefloatrrrboolrlistrrrrintrr r r rrs: 86 4 @  (rc@seZdZdddZdS)AsyncCullProtocolr Ncr )zSCull the store. This will remove all expired keys from the store. Nr rr r rcullwzAsyncCullProtocol.cull)r N)rr r!r,r r r rr*usr*c @s:eZdZdZd dddedBdedBdeefddZdS) AsyncEnumerateKeysProtocolz3Protocol segment to enumerate keys in a collection.Nlimitrr0r cr )a4List all keys in the specified collection. Args: collection: The collection to list the keys from. If no collection is provided, it will use the default collection. limit: The maximum number of keys to list. The behavior when no limit is provided is store-dependent. Nr )rrr0r r rrrzAsyncEnumerateKeysProtocol.keys)N)rr r!r"r#r)r(rr r r rr.s.r.c@s,eZdZdddedBdeefddZdS)!AsyncEnumerateCollectionsProtocolNr/r0r cr )zList all available collection names (may include empty collections). Args: limit: The maximum number of collections to list. The behavior when no limit is provided is store-dependent. Nr )rr0r r r collectionsz-AsyncEnumerateCollectionsProtocol.collections)rr r!r)r(r#r2r r r rr1s$r1c@seZdZdZdefddZdS)AsyncDestroyStoreProtocolz1Protocol segment for store-destruction semantics.r cr )z`Destroy the keystore. This will clear all collections and keys from the store. Nr r+r r rdestroyr-z!AsyncDestroyStoreProtocol.destroyN)rr r!r"r'r5r r r rr4sr4c@seZdZdedefddZdS)AsyncDestroyCollectionProtocolrr cr )zlDestroy the specified collection. Args: collection: The collection to destroy. Nr )rrr r rdestroy_collectionr3z1AsyncDestroyCollectionProtocol.destroy_collectionN)rr r!r#r'r7r r r rr6sr6c@seZdZdZdS) AsyncKeyValuezA protocol for key-value store operations. Includes basic operations: get, put, delete, ttl Includes bulk operations: get_many, put_many, delete_many, ttl_many. N)rr r!r"r r r rr8sr8N)collections.abcrtypingrrrrrr*r.r1r4r6r8r r r rs o