NgG|ddlmZddlZddlmZmZddlmZmZm Z ej dZ GddeZ dS) ) annotationsN)ABCabstractmethod)ListOptionalSequencei)intcbeZdZdZd$dZed%dZed%dZed&d Zed&d Z ed d d d'dZ ed d d d'dZ ed(dZ ed(dZ ed d d d dd)d Zed d d d dd)d!Zed*d"Zed*d#Zd S)+ RecordManagerz)Abstract base class for a record manager. namespacestrreturnNonec||_dS)zyInitialize the record manager. Args: namespace (str): The namespace for the record manager. N)r )selfr s \/var/www/html/ai-engine/env/lib/python3.11/site-packages/langchain_community/indexes/base.py__init__zRecordManager.__init__ s#cdSz2Create the database schema for the record manager.Nrs r create_schemazRecordManager.create_schemarc KdSrrrs racreate_schemazRecordManager.acreate_schema rfloatcdSa*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 KdSr rrs r aget_timezRecordManager.aget_time+rrN) group_ids time_at_leastkeys Sequence[str]r$!Optional[Sequence[Optional[str]]]r%Optional[float]cdSaUpsert 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&r$r%s rupdatezRecordManager.update6rrc KdSr+rr,s raupdatezRecordManager.aupdateJrr List[bool]cdSzCheck 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 KdSr2rr3s raexistszRecordManager.aexistsirr)beforeafterr$limitr7r8Optional[Sequence[str]]r9 Optional[int] List[str]cdSaList 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. Nrrr7r8r$r9s r list_keyszRecordManager.list_keystrrc KdSr>rr?s r alist_keyszRecordManager.alist_keysrrcdSzoDelete specified records from the database. Args: keys: A list of keys to delete. Nrr3s r delete_keyszRecordManager.delete_keysrrc KdSrDrr3s r adelete_keyszRecordManager.adelete_keysrr)r r rr)rr)rr)r&r'r$r(r%r)rr)r&r'rr0) r7r)r8r)r$r:r9r;rr<)r&r'rr)__name__ __module__ __qualname____doc__rrrrr!r#r-r/r4r6r@rBrErGrrrr r s 33 # # # #AAA^AAAA^A   ^    ^  8<)-      ^ & 8<)-      ^ &   ^    ^ #'!%-1#      ^ (#'!%-1#      ^ (   ^    ^   rr ) __future__ruuidabcrrtypingrrrUUIDNAMESPACE_UUIDr rrrrRs"""""" ########++++++++++t$$$b b b b b Cb b b b b r