o gZhQ@sLddlZddlmZmZddlmZddlmZm Z m Z GdddeZ dS)N)ObjectApiResponseTextApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc'@seZdZeddddddejeejefdedej e dej ejeejefdej e dej e d e ej fd d Z eddddddejeejefdej e dej ejeejefdej e dej e d e ej f d d Zedddddddddddddd dej ejeejefdej e dej ejeejefdej e dej e dej ejddefdej ejddefdej e dej edej ejdefdej edej ejddefdej ejdefd efddZedddddddddd dej ejeejefdej ejeejefdej e dej ejeejefdej e dej e dej ejddefdej e dej ejddefd e ej fdd Zed!d"dddddddd#dej ejeejefdej e dej ejeejefdej e dej e d$ej edej ejddefd e ej fd%d&Zedddddddddddddddddd'dej ejeejefdej ejeejefd(ej ejeejefd)ej ejeejefdej e d*ej ejeejefd+ej ejeejefdej ejeejefd,ej e dej e d-ej e d.ej e d/ej ejd0efdej ejddefdej e dej ejddefd1ej ejed e ej f$d2d3Zedddddddd4dej ejeejefdej ejeejefdej e dej ejeejefdej e dej e dej ejddefd e ej fd5d6ZdS)7 NodesClientN) error_trace filter_pathhumanprettynode_idmax_archive_versionr r r r returnc s|tvr td|tvrtddt|dt|}i}|dur'||d<|dur/||d<|dur7||d<|dur?||d <d d i} |jd ||| d IdHS)a Removes the archived repositories metering information present in the cluster. ``_ :param node_id: Comma-separated list of node IDs or names used to limit returned information. All the nodes selective options are explained [here](https://www.elastic.co/guide/en/elasticsearch/reference/current/cluster.html#cluster-nodes). :param max_archive_version: Specifies the maximum [archive_version](https://www.elastic.co/guide/en/elasticsearch/reference/current/get-repositories-metering-api.html#get-repositories-metering-api-response-body) to be cleared from the archive. *Empty value passed for parameter 'node_id'z6Empty value passed for parameter 'max_archive_version'/_nodes/z/_repositories_metering/Nr r r r acceptapplication/jsonDELETEparamsheadersr ValueErrorrperform_request) selfrrr r r r _NodesClient__path_NodesClient__query_NodesClient__headersr X/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_async/client/nodes.py#clear_repositories_metering_archives& z/NodesClient.clear_repositories_metering_archivec s|tvr tddt|d}i}|dur||d<|dur#||d<|dur+||d<|dur3||d<d d i}|jd |||d IdHS) a Returns cluster repositories metering information. ``_ :param node_id: Comma-separated list of node IDs or names used to limit returned information. All the nodes selective options are explained [here](https://www.elastic.co/guide/en/elasticsearch/reference/current/cluster.html#cluster-nodes). rrz/_repositories_meteringNr r r r rrGETrr) rrr r r r rrrr r r!get_repositories_metering_infoCs" z*NodesClient.get_repositories_metering_info) rr r r ignore_idle_threadsintervalmaster_timeoutr snapshotssortthreadstimeouttyper%r&z t.Literal[-1]z t.Literal[0]r'r(r)z/t.Literal['block', 'cpu', 'gpu', 'mem', 'wait']r*r+r,c s|tvrdt|d}nd}i}|dur||d<|dur"||d<|dur*||d<|dur2||d<|dur:||d <|durB||d <|durJ||d <| durR| |d <| durZ| |d <| durb| |d<| durj| |d<| durr| |d<ddi}|jd|||dIdHS)az Returns information about hot threads on each node in the cluster. ``_ :param node_id: List of node IDs or names used to limit returned information. :param ignore_idle_threads: If true, known idle threads (e.g. waiting in a socket select, or to get a task from an empty queue) are filtered out. :param interval: The interval to do the second sampling of threads. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param snapshots: Number of samples of thread stacktrace. :param sort: The sort order for 'cpu' type (default: total) :param threads: Specifies the number of hot threads to provide information for. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. :param type: The type to sample. rz /hot_threadsz/_nodes/hot_threadsNr r r r%r&r'r r(r)r*r+r,rz text/plainr#rrrr)rrr r r r%r&r'r r(r)r*r+r,rrrr r r! hot_threadsfsB+ zNodesClient.hot_threads) rmetricr r flat_settingsr r'r r+r/r0c s|tvr|tvrdt|dt|} n|tvr"dt|} n|tvr.dt|} nd} i} |dur:|| d<|durB|| d<|durJ|| d<|durR|| d<|durZ|| d <|durb|| d <| durj| | d <d d i} |jd| | | dIdHS)a] Returns information about nodes in the cluster. ``_ :param node_id: Comma-separated list of node IDs or names used to limit returned information. :param metric: Limits the information returned to the specific metrics. Supports a comma-separated list, such as http,ingest. :param flat_settings: If true, returns settings in flat format. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. r/z/_nodesNr r r0r r'r r+rrr#rr-) rrr/r r r0r r'r r+rrrr r r!infos6  zNodesClient.infoT)Z body_fields)rr r r r secure_settings_passwordr+r3c s|tvrdt|d}nd}i} i} |dur|| d<|dur$|| d<|dur,|| d<|dur4|| d<|dur<|| d <|durD|| d <| sHd} d d i} | durTd | d <|jd|| | | dIdHS)a Reloads secure settings. ``_ :param node_id: The names of particular nodes in the cluster to target. :param secure_settings_password: The password for the Elasticsearch keystore. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. rz/reload_secure_settingsz/_nodes/reload_secure_settingsNr r r r r3r+rrz content-typePOST)rrbodyr-) rrr r r r r3r+rrZ_NodesClient__bodyrr r r!reload_secure_settingss4  z"NodesClient.reload_secure_settings)rr/ index_metriccompletion_fieldsr fielddata_fieldsfieldsr groupsr include_segment_file_sizesinclude_unloaded_segmentslevelr'r r+typesr7r8r9r:r;r<r=r>z)t.Literal['cluster', 'indices', 'shards']r?cs|tvr|tvr|tvrdt|dt|dt|}nE|tvr4|tvr4dt|dt|}n0|tvrI|tvrIdt|dt|}n|tvrVdt|d}n|tvrbdt|}nd}i}|durn||d<|durv||d <|dur~||d <|dur||d <|dur||d <| dur| |d <| dur| |d<| dur| |d<| dur| |d<| dur| |d<|dur||d<|dur||d<|dur||d<|dur||d<ddi}|jd|||dIdHS)a Returns statistical information about nodes in the cluster. ``_ :param node_id: Comma-separated list of node IDs or names used to limit returned information. :param metric: Limit the information returned to the specified metrics :param index_metric: Limit the information returned for indices metric to the specific index metrics. It can be used only if indices (or all) metric is specified. :param completion_fields: Comma-separated list or wildcard expressions of fields to include in fielddata and suggest statistics. :param fielddata_fields: Comma-separated list or wildcard expressions of fields to include in fielddata statistics. :param fields: Comma-separated list or wildcard expressions of fields to include in the statistics. :param groups: Comma-separated list of search groups to include in the search statistics. :param include_segment_file_sizes: If true, the call reports the aggregated disk usage of each one of the Lucene index files (only applies if segment stats are requested). :param include_unloaded_segments: If `true`, the response includes information from segments that are not loaded into memory. :param level: Indicates whether statistics are aggregated at the cluster, index, or shard level. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. :param types: A comma-separated list of document types for the indexing index metric. rz/stats/r1z/_nodes/stats/z/statsz /_nodes/statsNr8r r9r:r r;r r<r=r>r'r r+r?rrr#rr-)rrr/r7r8r r9r:r r;r r<r=r>r'r r+r?rrrr r r!stats"s^=$ zNodesClient.stats)rr/r r r r r+c s|tvr|tvrdt|dt|}n|tvr#dt|d}n|tvr/dt|}nd}i} |dur;|| d<|durC|| d<|durK|| d <|durS|| d <|dur[|| d <d d i} |jd|| | dIdHS)a Returns low-level information about REST actions usage on nodes. ``_ :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 metric: Limits the information returned to the specific metrics. A comma-separated list of the following options: `_all`, `rest_actions`. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. rz/usage/z/usagez/_nodes/usage/z /_nodes/usageNr r r r r+rrr#rr-) rrr/r r r r r+rrrr r r!usages. zNodesClient.usage)__name__ __module__ __qualname__rtUnionstrSequenceintOptionalboolrAnyr"r$rr.r2r6r@rAr r r r!r s ' "      L    ;  0       m  r ) typingrEZelastic_transportrr_baserutilsrrrr r r r r!s