o gZhW@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 Cs||tvrtddt|}i}|dur||d<|dur!||d<|dur)||d<|dur1||d<dd i}|jd |||d S) 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__headersrZ/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/logstash.pydelete_pipelines zLogstashClient.delete_pipelinec Cs|tvrtd|tvrdt|}nd}i}|dur ||d<|dur(||d<|dur0||d<|dur8||d<d d i}|jd |||d S) 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 Cs|tvrtd|durtddt|}i}|dur!||d<|dur)||d<|dur1||d<|dur9||d<|} d d d } |jd ||| | d S) 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