o gZh{@sHddlZddlmZddlmZddlmZmZm Z GdddeZ dS)N)ObjectApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc@sVeZdZeddddddedejedejejeej efdejedejede ej f d d Z eddddddejeej efdejedejejeej efdejedejede ej f d d Z ed ddddddded ejeej fdejedejejeej efdejedejede ej fddZdS)LogstashClientN) error_trace filter_pathhumanprettyidr r r r returnc s|tvr tddt|}i}|dur||d<|dur"||d<|dur*||d<|dur2||d<dd i}|jd |||d IdHS) z Deletes Logstash Pipelines used by Central Management ``_ :param id: Identifier for the pipeline. %Empty value passed for parameter 'id'/_logstash/pipeline/Nr r r r acceptapplication/jsonDELETEparamsheadersr ValueErrorrZperform_request selfr r r r r _LogstashClient__path_LogstashClient__query_LogstashClient__headersr[/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_async/client/logstash.pydelete_pipelines" zLogstashClient.delete_pipelinec s|tvr td|tvrdt|}nd}i}|dur!||d<|dur)||d<|dur1||d<|dur9||d<d d i}|jd |||d IdHS) z Retrieves Logstash Pipelines used by Central Management ``_ :param id: Comma-separated list of pipeline identifiers. rrz/_logstash/pipelineNr r r r rrGETrrrrrr get_pipeline=s& zLogstashClient.get_pipelinepipeline)Z body_namec s|tvr td|durtddt|}i}|dur"||d<|dur*||d<|dur2||d<|dur:||d<|} d d d } |jd ||| | d IdHS) a Adds and updates Logstash Pipelines used for Central Management ``_ :param id: Identifier for the pipeline. :param pipeline: rNz+Empty value passed for parameter 'pipeline'rr r r r r)rz content-typePUT)rrbodyr) rr r#r r r r rrZ_LogstashClient__bodyrrrr put_pipelinebs(   zLogstashClient.put_pipeline)__name__ __module__ __qualname__rstrtOptionalboolUnionSequencerAnyr r"Mappingr&rrrrrsv ! $ r) typingr+Zelastic_transportr_baserutilsrrrrrrrrs