o .ife@sXddlmZddlZddlmZmZddlmZmZm Z ej ddZ GdddeZ dS) ) annotationsN)ABCabstractmethod)ListOptionalSequencei)intc@seZdZdZd1ddZed2dd Zed2d d Zed3d dZed3ddZ edddd4ddZ edddd4ddZ ed5ddZ ed5d d!Z eddddd"d6d)d*Zeddddd"d6d+d,Zed7d-d.Zed7d/d0ZdS)8 RecordManagerzGAn abstract base class representing the interface for a record manager. namespacestrreturnNonecCs ||_dS)zyInitialize the record manager. Args: namespace (str): The namespace for the record manager. N)r )selfr rO/var/www/html/corbot_env/lib/python3.10/site-packages/langchain/indexes/base.py__init__ s zRecordManager.__init__cCdSz2Create the database schema for the record manager.Nrrrrr create_schemazRecordManager.create_schemacdSrrrrrracreate_schemazRecordManager.acreate_schemafloatcCra*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. Nrrrrrget_time rzRecordManager.get_timecrrrrrrr aget_time+rzRecordManager.aget_timeN) group_ids time_at_leastkeys Sequence[str]r!Optional[Sequence[Optional[str]]]rOptional[float]cCraUpsert 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. Nrrr rrrrrupdate6rzRecordManager.updatecrr$rr%rrraupdateJrzRecordManager.aupdate List[bool]cCrzCheck 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 rrrexists^rzRecordManager.existscrr)rr*rrraexistsirzRecordManager.aexists)beforeafterrlimitr-r.Optional[Sequence[str]]r/ Optional[int] List[str]cCraList 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. Nrrr-r.rr/rrr list_keystrzRecordManager.list_keyscrr3rr4rrr alist_keysrzRecordManager.alist_keyscCrzoDelete specified records from the database. Args: keys: A list of keys to delete. Nrr*rrr delete_keysrzRecordManager.delete_keyscrr7rr*rrr adelete_keysrzRecordManager.adelete_keys)r r r r )r r )r r)r r!rr"rr#r r )r r!r r() r-r#r.r#rr0r/r1r r2)r r!r r )__name__ __module__ __qualname____doc__rrrrrrr&r'r+r,r5r6r8r9rrrrr sN          r ) __future__ruuidabcrrtypingrrrUUIDNAMESPACE_UUIDr rrrrs