o gZh(@sHddlZddlmZddlmZddlmZmZm Z GdddeZ dS)N)ObjectApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc@seZdZeddddddddedejedejejeej efdejedejejdefd ejed ejejdefd e ej fd d Z edddddddddejejeej efdejedejejeej efdejedejejdefd ejed ejejdefd e ej fddZ eddddddddddddededejdefdejedejedejejeej efdejedejejdefd ejedejed ejejdefd e ej fddZdS)ShutdownClientN) error_trace filter_pathhumanmaster_timeoutprettytimeoutnode_idr r r r z6t.Literal['d', 'h', 'm', 'micros', 'ms', 'nanos', 's']r rreturnc Cs|tvrtddt|d}i} |dur|| d<|dur"|| d<|dur*|| d<|dur2|| d<|dur:|| d <|durB|| d <d d i} |jd || | dS)a Removes a node from the shutdown list. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported. ``_ :param node_id: The node id of node to be removed from the shutdown state :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. *Empty value passed for parameter 'node_id'/_nodes/ /shutdownNr r r r r racceptapplication/jsonDELETEparamsheadersr ValueErrorrperform_request selfrr r r r r r_ShutdownClient__path_ShutdownClient__query_ShutdownClient__headersr"Z/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/shutdown.py delete_nodes(zShutdownClient.delete_node)rr r r r r rc Cs|tvr dt|d}nd}i} |dur|| d<|dur!|| d<|dur)|| d<|dur1|| d<|dur9|| d <|durA|| d <d d i} |jd || | dS)a Retrieve status of a node or nodes that are currently marked as shutting down. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported. ``_ :param node_id: Which node for which to retrieve the shutdown status :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. rrz/_nodes/shutdownNr r r r r rrrGETr)rrrrr"r"r#get_nodeMs(zShutdownClient.get_nodeT)Z body_fields)allocation_delayr r r r r target_node_namerreasontypez)t.Literal['remove', 'replace', 'restart']r'r(c Cs|tvrtd|durtd|durtddt|d} i} i}|dur,|| d<|dur4|| d<|dur<|| d <|durD||d <|durL||d <|durT||d <|dur\||d <| durd| |d<| durl| | d<| durt| |d<ddd}|jd| ||| dS)a Adds a node to be shut down. Designed for indirect use by ECE/ESS and ECK. Direct use is not supported. ``_ :param node_id: The node id of node to be shut down :param reason: A human-readable reason that the node is being shut down. This field provides information for other cluster operators; it does not affect the shut down process. :param type: Valid values are restart, remove, or replace. Use restart when you need to temporarily shut down a node to perform an upgrade, make configuration changes, or perform other maintenance. Because the node is expected to rejoin the cluster, data is not migrated off of the node. Use remove when you need to permanently remove a node from the cluster. The node is not marked ready for shutdown until data is migrated off of the node Use replace to do a 1:1 replacement of a node with another node. Certain allocation decisions will be ignored (such as disk watermarks) in the interest of true replacement of the source node with the target node. During a replace-type shutdown, rollover and index creation may result in unassigned shards, and shrink may fail until the replacement is complete. :param allocation_delay: Only valid if type is restart. Controls how long Elasticsearch will wait for the node to restart and join the cluster before reassigning its shards to other nodes. This works the same as delaying allocation with the index.unassigned.node_left.delayed_timeout setting. If you specify both a restart allocation delay and an index-level allocation delay, the longer of the two is used. :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 target_node_name: Only valid if type is replace. Specifies the name of the node that is replacing the node being shut down. Shards from the shut down node are only allowed to be allocated to the target node, and no other data will be allocated to the target node. During relocation of data certain allocation rules are ignored, such as disk watermarks or user attribute filtering rules. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. rNz)Empty value passed for parameter 'reason'z'Empty value passed for parameter 'type'rrr)r*r'r r r r r r(rr)rz content-typePUT)rrbodyr)rrr)r*r'r r r r r r(rrZ_ShutdownClient__bodyr r!r"r"r#put_nodesB=  zShutdownClient.put_node)__name__ __module__ __qualname__rstrtOptionalboolUnionSequencerAnyr$r&r-r"r"r"r#rs    1    2      r) typingr2Zelastic_transportr_baserutilsrrrrr"r"r"r#s