o gZh]Q@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 Cs|tvrtd|tvrtddt|dt|}i}|dur&||d<|dur.||d<|dur6||d<|dur>||d <d d i} |jd ||| d S)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 W/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/nodes.py#clear_repositories_metering_archives$z/NodesClient.clear_repositories_metering_archivec Cs~|tvrtddt|d}i}|dur||d<|dur"||d<|dur*||d<|dur2||d<d d i}|jd |||d S) 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 Cs|tvr dt|d}nd}i}|dur||d<|dur!||d<|dur)||d<|dur1||d<|dur9||d <|durA||d <|durI||d <| durQ| |d <| durY| |d <| dura| |d<| duri| |d<| durq| |d<ddi}|jd|||dS)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_threadsfs@+zNodesClient.hot_threads) rmetricr r flat_settingsr r'r r+r/r0c Cs|tvr|tvrdt|dt|} n|tvr!dt|} n|tvr-dt|} nd} i} |dur9|| d<|durA|| d<|durI|| d<|durQ|| d<|durY|| d <|dura|| d <| duri| | d <d d i} |jd| | | dS)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!infos4 zNodesClient.infoT)Z body_fields)rr r r r secure_settings_passwordr+r3c Cs|tvr dt|d}nd}i} i} |dur|| d<|dur#|| d<|dur+|| d<|dur3|| d<|dur;|| d <|durC|| d <| sGd} d d i} | durSd | d <|jd|| | | dS)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_settingss2 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?cCs|tvr|tvr|tvrdt|dt|dt|}nE|tvr3|tvr3dt|dt|}n0|tvrH|tvrHdt|dt|}n|tvrUdt|d}n|tvradt|}nd}i}|durm||d<|duru||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|||dS)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 Cs|tvr|tvrdt|dt|}n|tvr"dt|d}n|tvr.dt|}nd}i} |dur:|| d<|durB|| d<|durJ|| d <|durR|| d <|durZ|| d <d d i} |jd|| | dS)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