ci8ddlmZmZmZmZmZmZddlmZm Z ddl m Z edZ Gddee Z Gdd e eZ e ZejZejZejZejZejZd S) )AnyDictGenericTypeTypeVarUnion) Elasticsearch__versionstr__) serializer_TceZdZdZdeefdZdeddfdZde d eddfd Z de ddfd Z dde dedefd Z dde e efdefdZd edefdZdS) Connectionszr Class responsible for holding connections to different clusters. Used as a singleton in this module. elasticsearch_classc0i|_i|_||_dS)N)_kwargs_connsr)selfrs ]/var/www/html/auto_sub_bot/venv/lib/python3.11/site-packages/elasticsearch/dsl/connections.py__init__zConnections.__init__!s') %' -@   kwargsreturnNc t|jD]9}||jvr&||d|j|kr1|j|=:||_dS)a Configure multiple connections at once, useful for passing in config dictionaries obtained from other sources, like Django's settings or a configuration management tool. Example:: connections.configure( default={'hosts': 'localhost'}, dev={'hosts': ['esdev1.example.com:9200'], 'sniff_on_start': True}, ) Connections will only be constructed lazily when requested through ``get_connection``. N)listrrget)rrks r configurezConnections.configure&sa dk""  ADL  VZZ4%8%8DLO%K%K A raliasconnc@|||j|<dS)zK Add a connection object, it will be passed through as-is. N)_with_user_agentr)rrr s radd_connectionzConnections.add_connection=s$"22488 Ercd}|j|jfD]} ||=#t$r|dz }YwxYw|dkrtd|ddS)zn Remove connection from the registry. Raises ``KeyError`` if connection wasn't found. rr "There is no connection with alias .N)rrKeyError)rrerrorsds rremove_connectionzConnections.remove_connectionCs +t|,  A eHH   !   Q;;JJJJKK K ;s **defaultc |dt|jdi|x}|j|<||S)zu Construct an instance of ``elasticsearch.Elasticsearch`` and register it under given alias. r ) setdefaultr rrr")rrrr s rcreate_connectionzConnections.create_connectionRsR , 333$r?r rr __classcell__)rFs@rrBrBscERBBBtM/BBBBBBBBBBBrrBN)typingrrrrrr elasticsearchr r r r rrB connectionsrr#r+r0r4r.rrrKs$<;;;;;;;;;;;;;;;77777777"""""" WT]]fffff'"+fffRBBBBB{=9BBB '&((  ! +11+r