o gZh'@sHddlZddlmZddlmZddlmZmZm Z GdddeZ dS)N)ObjectApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc@seZdZeddddddddejejeejefdeje dejejeejefdeje dejejdd efd eje d e ej fd d Z eddddddddddejejeejefdeje deje dejejejejdefejdeffdejejeejefdeje deje d eje d e ej fddZ eddddddddddddd dedededeje dejejeejefdeje dejejedejejeej fdejejdd efd eje dejedejedeje d e ej fd d!Zeddddddd"dejejeejefdeje dejejeejefdeje d#ejejd$efd eje d e ej fd%d&ZdS)'SearchableSnapshotsClientN)node_id error_trace filter_pathhumanmaster_timeoutprettyr r r r r z t.Literal[-1]z t.Literal[0]rreturnc Cs|tvr dt|d}nd}i}|dur||d<|dur!||d<|dur)||d<|dur1||d<|dur9||d <d d i} |jd ||| d S)a Retrieve node-level cache statistics about searchable snapshots. ``_ :param node_id: A comma-separated list of node IDs or names to limit the returned information; use `_local` to return information from the node you're connecting to, leave empty to get information from all nodes :param master_timeout: z/_searchable_snapshots/z /cache/statsz"/_searchable_snapshots/cache/statsNr r r r racceptapplication/jsonGETparamsheadersrrperform_request) selfr r r r r r _SearchableSnapshotsClient__path!_SearchableSnapshotsClient__query#_SearchableSnapshotsClient__headersrf/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/searchable_snapshots.py cache_statss$z%SearchableSnapshotsClient.cache_stats)indexallow_no_indicesr expand_wildcardsr r ignore_unavailablerrr r!z4t.Literal['all', 'closed', 'hidden', 'none', 'open']r"c Cs|tvr dt|d} nd} i} |dur|| d<|dur!|| d<|dur)|| d<|dur1|| d<|dur9|| d<|durA|| d <|durI|| d <d d i} |jd | | | dS)a Clear the cache of searchable snapshots. ``_ :param index: A comma-separated list of index names :param allow_no_indices: Whether to ignore if a wildcard indices expression resolves into no concrete indices. (This includes `_all` string or when no indices have been specified) :param expand_wildcards: Whether to expand wildcard expression to concrete indices that are open, closed or both. :param ignore_unavailable: Whether specified concrete indices should be ignored when unavailable (missing or closed) /z"/_searchable_snapshots/cache/clearNr r r!r r r"rrrPOSTrr) rrr r r!r r r"rrrrrrr clear_cacheFs,"z%SearchableSnapshotsClient.clear_cacheT)Z body_fields) r r r ignore_index_settingsindex_settingsr r renamed_indexstoragewait_for_completion repositorysnapshotr&r'r(r)r*c Cs |tvrtd|tvrtd|durtddt|dt|d}i}i}|dur1||d<|dur9||d <|durA||d <|durI||d <|durQ||d <|durY||d <| dura| |d<| duri| |d<| durq| |d<| dury| |d<| dur| |d<ddd}|jd||||dS)aD Mount a snapshot as a searchable index. ``_ :param repository: The name of the repository containing the snapshot of the index to mount :param snapshot: The name of the snapshot of the index to mount :param index: :param ignore_index_settings: :param index_settings: :param master_timeout: Explicit operation timeout for connection to master node :param renamed_index: :param storage: Selects the kind of local storage used to accelerate searches. Experimental, and defaults to `full_copy` :param wait_for_completion: Should this request wait until the operation has completed before returning z-Empty value passed for parameter 'repository'z+Empty value passed for parameter 'snapshot'Nz(Empty value passed for parameter 'index'z /_snapshot/r#z/_mountrr r r r&r'r rr(r)r*r)rz content-typer$)rrbody)r ValueErrorrr)rr+r,rr r r r&r'r rr(r)r*rZ _SearchableSnapshotsClient__bodyrrrrrmountsF(  zSearchableSnapshotsClient.mount)rr r r levelrr0z)t.Literal['cluster', 'indices', 'shards']c Cs|tvr dt|d}nd}i}|dur||d<|dur!||d<|dur)||d<|dur1||d<|dur9||d<d d i} |jd ||| d S) aC Retrieve shard-level statistics about searchable snapshots. ``_ :param index: A comma-separated list of index names :param level: Return stats aggregated at cluster, index or shard level r#z/_searchable_snapshots/statsNr r r r0rrrrrr) rrr r r r0rrrrrrrstatss$zSearchableSnapshotsClient.stats)__name__ __module__ __qualname__rtOptionalUnionstrSequenceboolrAnyrr%Mappingr/r1rrrrrs  *   9     I   r) typingr5Zelastic_transportr_baserutilsrrrrrrrrs