a bgG@sXddlmZddlZddlmZmZddlmZmZm Z ej ddZ GdddeZ dS) ) annotationsN)ABCabstractmethod)ListOptionalSequencei)intc@sDeZdZdZdddddZedddd Zeddd d Zed dd dZed dddZ eddddddddddZ eddddddddddZ edddddZ eddddd Z eddddd!ddd"d#d$d%d&d'Zeddddd!ddd"d#d$d%d(d)Zedddd*d+Zedddd,d-ZdS). RecordManagerz)Abstract base class for a record manager.strNone) namespacereturncCs ||_dS)zyInitialize the record manager. Args: namespace (str): The namespace for the record manager. N)r )selfr rn/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/langchain_community/indexes/base.py__init__ s zRecordManager.__init__)r cCsdSz2Create the database schema for the record manager.Nrrrrr create_schemaszRecordManager.create_schemacsdSrrrrrracreate_schemaszRecordManager.acreate_schemafloatcCsdSa*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 szRecordManager.get_timecsdSrrrrrr aget_time+szRecordManager.aget_timeN) group_ids time_at_leastz Sequence[str]z!Optional[Sequence[Optional[str]]]zOptional[float])keysrrr cCsdSaUpsert 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. Nrrrrrrrrupdate6szRecordManager.updatecsdSrrrrrraupdateJszRecordManager.aupdatez List[bool])rr cCsdSzCheck 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. Nrrrrrrexists^szRecordManager.existscsdSr!rr"rrraexistsiszRecordManager.aexists)beforeafterrlimitzOptional[Sequence[str]]z Optional[int]z List[str])r%r&rr'r cCsdSaList 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_keysts zRecordManager.list_keyscsdSr(rr)rrr alist_keyss zRecordManager.alist_keyscCsdSzoDelete specified records from the database. Args: keys: A list of keys to delete. Nrr"rrr delete_keysszRecordManager.delete_keyscsdSr,rr"rrr adelete_keysszRecordManager.adelete_keys)__name__ __module__ __qualname____doc__rrrrrrrr r#r$r*r+r-r.rrrrr sL     r ) __future__ruuidabcrrtypingrrrUUIDZNAMESPACE_UUIDr rrrrs