o gZhR@sHddlZddlmZddlmZddlmZmZm Z GdddeZ dS)N)ObjectApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc@seZdZeddddddddedejedejejeej efdejedejejdd efd ejed ejejdd efd e ej fd dZ eddddddddddedejedejejeej efdejedejejdd efdejedejed ejed ejejdd efd e ej fddZ edddddddddejedejedejejeej efdejedejejdd efd ejed ejejdd efd e ej fddZeddddddejedejejeej efdejed ejed e ej f ddZedddddddddddejedejedejejeej efdejedejed ejed ejed e ej fd!d"Zeddddddddd#ded$ejejeej fdejedejejeej efdejed%ejejeej fd ejed e ej fd&d'Zedddddddddd(dedejedejejeej efdejedejejdd efd)ejejeej fd ejed ejejdd efd e ej fd*d+Zeddddddedejedejejeej efdejed ejed e ej f d,d-Zeddddddedejedejejeej efdejed ejed e ej f d.d/Zeddddddddejedejejeej efdejedejejdd efd ejed ejejdd efd e ej fd0d1Zeddddddddejedejejeej efdejedejejdd efd ejed ejejdd efd e ej fd2d3ZdS)4 IlmClientN) error_trace filter_pathhumanmaster_timeoutprettytimeoutnamer r r r z t.Literal[-1]z t.Literal[0]r rreturnc Cs|tvrtddt|}i} |dur|| d<|dur!|| d<|dur)|| d<|dur1|| d<|dur9|| d<|durA|| d <d d i} |jd || | d S)ay Deletes the specified lifecycle policy definition. A currently used policy cannot be deleted. ``_ :param name: Identifier for the policy. :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 'name' /_ilm/policy/Nr r r r r racceptapplication/jsonDELETEparamsheadersr ValueErrorrperform_request selfrr r r r r r_IlmClient__path_IlmClient__query_IlmClient__headersr!U/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/ilm.pydelete_lifecycles(zIlmClient.delete_lifecycle)r r r r only_errors only_managedr rindexr$r%c Cs|tvrtddt|d} i} |dur|| d<|dur"|| d<|dur*|| d<|dur2|| d<|dur:|| d <|durB|| d <|durJ|| d <| durR| | d <d di} |jd| | | dS)a Retrieves information about the index's current lifecycle state, such as the currently executing phase, action, and step. ``_ :param index: Comma-separated list of data streams, indices, and aliases to target. Supports wildcards (`*`). To target all data streams and indices, use `*` or `_all`. :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 only_errors: Filters the returned indices to only indices that are managed by ILM and are in an error state, either due to an encountering an error while executing the policy, or attempting to use a policy that does not exist. :param only_managed: Filters the returned indices to only indices that are managed by ILM. :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 'index'/z /_ilm/explainNr r r r r$r%r rrrGETrr) rr&r r r r r$r%r rrrr r!r!r"explain_lifecycleKs0$zIlmClient.explain_lifecycle)rr r r r r rc Cs|tvr dt|}nd}i} |dur|| d<|dur || d<|dur(|| d<|dur0|| d<|dur8|| d<|dur@|| d <d d i} |jd || | d S)au Returns the specified policy definition. Includes the policy version and last modified date. ``_ :param name: Identifier for the policy. :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. rz /_ilm/policyNr r r r r rrrr)r)rrrrr!r!r" get_lifecycles(zIlmClient.get_lifecycle)r r r r cCsbd}i}|dur ||d<|dur||d<|dur||d<|dur$||d<ddi}|jd |||d S) z Retrieves the current index lifecycle management (ILM) status. ``_ z /_ilm/statusNr r r r rrr)rr)rr r r r rrr r!r!r" get_statusszIlmClient.get_statusT)Z body_fields)dry_runr r r legacy_template_to_deletenode_attributer r.r/r0c Csd}i} i} |dur|| d<|dur|| d<|dur|| d<|dur&|| d<|dur.|| d<|dur6|| d<|dur>|| d <| sBd} d d i} | durNd | d <|jd || | | dS)aE Migrates the indices and ILM policies away from custom node attribute allocation routing to data tiers routing ``_ :param dry_run: If true, simulates the migration from node attributes based allocation filters to data tiers, but does not perform the migration. This provides a way to retrieve the indices and ILM policies that need to be migrated. :param legacy_template_to_delete: :param node_attribute: z/_ilm/migrate_to_data_tiersNr.r r r r/r0r rr content-typePOSTrrbodyr,) rr.r r r r/r0r rr_IlmClient__bodyr r!r!r"migrate_to_data_tierss2 zIlmClient.migrate_to_data_tiers) current_stepr r r next_stepr r7r8c Cs|tvrtddt|}i} i} |dur|| d<|dur#|| d<|dur+|| d<|dur3|| d<|dur;|| d<|durC|| d <| sGd} d d i} | durSd | d <|jd || | | dS)a@ Manually moves an index into the specified step and executes that step. ``_ :param index: The name of the index whose lifecycle step is to change :param current_step: :param next_step: r'z /_ilm/move/Nr7r r r r8r rrr1r2r3r) rr&r7r r r r8r rr5rr r!r!r" move_to_step s2 zIlmClient.move_to_step)r r r r policyr rr:c Cs|tvrtddt|} i} i} |dur|| d<|dur#|| d<|dur+|| d<|dur3|| d<|dur;|| d<|durC|| d <|durK|| d <| sOd} d d i} | dur[d | d <|jd| | | | dS)aB Creates a lifecycle policy ``_ :param name: Identifier for the policy. :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 policy: :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. rrNr r r r r:r rrrr1PUTr3r) rrr r r r r:r rrrr5r r!r!r" put_lifecycle;s6 zIlmClient.put_lifecyclec C~|tvrtddt|d}i}|dur||d<|dur"||d<|dur*||d<|dur2||d<d d i}|jd |||d S) a Removes the assigned lifecycle policy and stops managing the specified index ``_ :param index: The name of the index to remove policy on r'r(z /_ilm/removeNr r r r rrr2rr rr&r r r r rrr r!r!r" remove_policyus zIlmClient.remove_policyc Cr=) a/ Retries executing the policy for an index that is in the ERROR step. ``_ :param index: The name of the indices (comma-separated) whose failed lifecycle step is to be retry r'r(z /_ilm/retryNr r r r rrr2rrr>r!r!r"retrys zIlmClient.retryc Cd}i}|dur ||d<|dur||d<|dur||d<|dur$||d<|dur,||d<|dur4||d<d d i} |jd ||| d S) z Start the index lifecycle management (ILM) plugin. ``_ :param master_timeout: :param timeout: z /_ilm/startNr r r r r rrrr2rr, rr r r r r rrrr r!r!r"starts$zIlmClient.startc CrA) a  Halts all lifecycle management operations and stops the index lifecycle management (ILM) plugin ``_ :param master_timeout: :param timeout: z /_ilm/stopNr r r r r rrrr2rr,rBr!r!r"stops$zIlmClient.stop)__name__ __module__ __qualname__rstrtOptionalboolUnionSequencerAnyr#r*r+r-r6Mappingr9r<r?r@rCrDr!r!r!r"rs   /     <   0   1  .    7 ! "   '   r) typingrIZelastic_transportr_baserutilsrrrrr!r!r!r"s