7|hGxddlmZddlZddlmZmZddlmZmZm Z ejdZ GddeZ y) ) annotationsN)ABCabstractmethod)ListOptionalSequencei)intc`eZdZdZ ddZeddZeddZeddZeddZ eddd dd Z eddd dd Z edd Z edd Z eddddd  ddZeddddd  ddZeddZeddZy) RecordManagerz)Abstract base class for a record manager.c||_y)zyInitialize the record manager. Args: namespace (str): The namespace for the record manager. N) namespace)selfr s _/var/www/html/test/engine/venv/lib/python3.12/site-packages/langchain_community/indexes/base.py__init__zRecordManager.__init__ s #cyz2Create the database schema for the record manager.Nrs r create_schemazRecordManager.create_schemarc Kywrrrs racreate_schemazRecordManager.acreate_schemacya*Get the current server time as a high resolution timestamp! It's important to get this from the server to ensure a monotonic clock, otherwise there may be data loss when cleaning up old documents! Returns: The current server time as a float timestamp. Nrrs rget_timezRecordManager.get_time rrc Kywrrrs r aget_timezRecordManager.aget_time+rrN) group_ids time_at_leastcyaUpsert records into the database. Args: keys: A list of record keys to upsert. group_ids: A list of group IDs corresponding to the keys. time_at_least: if provided, updates should only happen if the updated_at field is at least this time. Raises: ValueError: If the length of keys doesn't match the length of group_ids. Nrrkeysr!r"s rupdatezRecordManager.update6rrc Kywr$rr%s raupdatezRecordManager.aupdateJrrcyzCheck if the provided keys exist in the database. Args: keys: A list of keys to check. Returns: A list of boolean values indicating the existence of each key. Nrrr&s rexistszRecordManager.exists^rrc Kywr+rr,s raexistszRecordManager.aexistsirr)beforeafterr!limitcyaList records in the database based on the provided filters. Args: before: Filter to list records updated before this time. after: Filter to list records updated after this time. group_ids: Filter to list records with specific group IDs. limit: optional limit on the number of records to return. Returns: A list of keys for the matching records. Nrrr0r1r!r2s r list_keyszRecordManager.list_keystrrc Kywr4rr5s r alist_keyszRecordManager.alist_keysrrcyzoDelete specified records from the database. Args: keys: A list of keys to delete. Nrr,s r delete_keyszRecordManager.delete_keysrrc Kywr:rr,s r adelete_keyszRecordManager.adelete_keysrr)r strreturnNone)r?r@)r?float)r& Sequence[str]r!z!Optional[Sequence[Optional[str]]]r"Optional[float]r?r@)r&rBr?z List[bool]) r0rCr1rCr!zOptional[Sequence[str]]r2z Optional[int]r?z List[str])r&rBr?r@)__name__ __module__ __qualname____doc__rrrrrr r'r)r-r/r6r8r;r=rrrr r s3 # #  #AAAA     8<)-   5  '     & 8<)-   5  '     &    #'!%-1#      +       (#'!%-1#      +       (    rr ) __future__ruuidabcrrtypingrrrUUIDNAMESPACE_UUIDr rrrrNs2" #++t$b Cb r