KiYddlmZmZddlmZmZmZmZeGddeZeGddeZ eGddeZ eGd d eZ eGd d eZ eGd deZ GddeeZy))MappingSequence)AnyProtocol SupportsFloatruntime_checkablec eZdZdZdddededzdeeefdzfdZdddededzdeeeefdze dzffdZ ddd ded e eefdedzd e dzddf d Z dddededzdefd ZdddeededzdeeeefdzfdZdddeededzdeeeeefdze dzffdZddd deedee eefdedzd e dzddf dZdddeededzdefdZy)AsyncKeyValueProtocolabA subset of KV operations: get/put/delete and TTL variants, including bulk calls. This protocol defines the minimal contract for key-value store implementations. All methods may raise exceptions on connection failures, validation errors, or other operational issues. Implementations should handle backend-specific errors appropriately. N) collectionkeyr returnc Kyw)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 r s m/home/jay/workspace/scripts/.codegraph-venv/lib/python3.12/site-packages/key_value/aio/protocols/key_value.pygetzAsyncKeyValueProtocol.gets  c Kyw)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. Nrrs rttlzAsyncKeyValueProtocol.ttl  r)r rvaluerc Kyw)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 rr rs rputzAsyncKeyValueProtocol.put-  rc Kyw)a_Delete 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. Returns: True if the key was deleted, False if the key did not exist. Nrrs rdeletezAsyncKeyValueProtocol.delete9rrkeysc Kyw)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. Nrrrr s rget_manyzAsyncKeyValueProtocol.get_manyErrc Kyw)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. Nrr s rttl_manyzAsyncKeyValueProtocol.ttl_manyQrrvaluesc Kyw)aLStore 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 all key-value pairs. The same TTL will be applied to all items in the batch. Defaults to no TTL. Note: The backend store will convert the provided format to its own internal format. Nr)rrr$r rs rput_manyzAsyncKeyValueProtocol.put_many^s $ rc Kyw)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. Nrr s r delete_manyz!AsyncKeyValueProtocol.delete_manyrrr)__name__ __module__ __qualname____doc__strdictrrtuplefloatrrrrboolrrlistr!r#r&intr(rrr r s!"&   $J  c3h$   "?C  S  t  uTRUWZRZ^^bMbdilpdpMpGq  Y]z~  S  c):  3QU:  cpswcw  DH  BF    C$J  $  OS  8C=  t  W[\`adfiai\jmq\qWr  OS  8C=  t  W[\abfgjlogobpswbwy~BFzFcF]GXH  $"&$(  sm c*+ $J  T !    (RV  hsm  C$J  Z]  r4r ceZdZddZy)AsyncCullProtocolNc Kyw)zSCull the store. This will remove all expired keys from the store. Nrrs rcullzAsyncCullProtocol.cull r)r N)r)r*r+r9rr4rr6r6s r4r6c >eZdZdZddddedzdedzdeefdZy) AsyncEnumerateKeysProtocolz3Protocol segment to enumerate keys in a collection.Nlimitr r>r c Kyw)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)rr r>s rrzAsyncEnumerateKeysProtocol.keyss  r)N)r)r*r+r,r-r3r2rrr4rr<r<s5= t S4Z #* X\]`Xa r4r<c.eZdZdddedzdeefdZy)!AsyncEnumerateCollectionsProtocolNr=r>r c Kyw)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)rr>s r collectionsz-AsyncEnumerateCollectionsProtocol.collections r)r)r*r+r3r2r-rCrr4rrArAs 7; #* S  r4rAceZdZdZdefdZy)AsyncDestroyStoreProtocolz1Protocol segment for store-destruction semantics.r c Kyw)z`Destroy the keystore. This will clear all collections and keys from the store. Nrr8s rdestroyz!AsyncDestroyStoreProtocol.destroyr:rN)r)r*r+r,r1rHrr4rrFrFs; t r4rFceZdZdedefdZy)AsyncDestroyCollectionProtocolr r c Kyw)zlDestroy the specified collection. Args: collection: The collection to destroy. Nr)rr s rdestroy_collectionz1AsyncDestroyCollectionProtocol.destroy_collectionrDrN)r)r*r+r-r1rLrr4rrJrJs 3 4 r4rJceZdZdZy) 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)r)r*r+r,rr4rrNrNsr4rNN)collections.abcrrtypingrrrrr r6r<rArFrJrNrr4rrQs-BBv Hv v r                X  )8r4