3 ]@s,ddlmZmZmZmZGdddeZdS))NamespacedClient query_params _make_path SKIP_IN_PATHc@seZdZedddZedddZedddZeddd Zed d d d Zed!d dZ eddddd"ddZ ed#ddZ edd$ddZ ed%ddZ dS)& WatcherClientNcCs.|tkrtd|jjdtdd|d||dS)z ``_ :arg watch_id: Watch ID :arg action_id: A comma-separated list of the action ids to be acked z6Empty value passed for a required argument 'watch_id'.PUT_watcherwatchZ_ack)params)r ValueError transportperform_requestr)selfwatch_idZ action_idr rK/tmp/pip-build-z81i1n8o/elasticsearch/elasticsearch/client/xpack/watcher.py ack_watchs zWatcherClient.ack_watchcCs,|tkrtd|jjdtdd|d|dS)z ``_ :arg watch_id: Watch ID z6Empty value passed for a required argument 'watch_id'.rrr Z _activate)r )rr r r r)rrr rrractivate_watchszWatcherClient.activate_watchcCs,|tkrtd|jjdtdd|d|dS)z ``_ :arg watch_id: Watch ID z6Empty value passed for a required argument 'watch_id'.rrr Z _deactivate)r )rr r r r)rrr rrrdeactivate_watch"s  zWatcherClient.deactivate_watchcCs*|tkrtd|jjdtdd||dS)z ``_ :arg id: Watch ID z0Empty value passed for a required argument 'id'.DELETErr )r )rr r r r)ridr rrr delete_watch1szWatcherClient.delete_watchdebugcCs|jjdtdd|d||dS)a ``_ :arg id: Watch ID :arg body: Execution control :arg debug: indicates whether the watch should execute in debug mode rrr Z_execute)r body)r r r)rrrr rrr execute_watch>s  zWatcherClient.execute_watchcCs*|tkrtd|jjdtdd||dS)z ``_ :arg id: Watch ID z0Empty value passed for a required argument 'id'.GETrr )r )rr r r r)rrr rrr get_watchNszWatcherClient.get_watchactiveZif_primary_termZ if_seq_noversioncCs,|tkrtd|jjdtdd|||dS)aR ``_ :arg id: Watch ID :arg body: The watch :arg active: Specify whether the watch is in/active by default :arg if_primary_term: only update the watch if the last operation that has changed the watch has the specified primary term :arg if_seq_no: only update the watch if the last operation that has changed the watch has the specified sequence number :arg version: Explicit version number for concurrency control z0Empty value passed for a required argument 'id'.rrr )r r)rr r r r)rrrr rrr put_watch[szWatcherClient.put_watchcCs|jjdd|dS)zl ``_ POSTz/_watcher/_start)r )r r )rr rrrstartoszWatcherClient.startZemit_stacktracescCs|jjdtdd||dS)a% ``_ :arg metric: Controls what additional stat metrics should be include in the response :arg emit_stacktraces: Emits stack traces of currently running watches rrstats)r )r r r)rZmetricr rrrr"vs zWatcherClient.statscCs|jjdd|dS)zk ``_ r z/_watcher/_stop)r )r r )rr rrrstopszWatcherClient.stop)NN)N)N)N)NNN)N)NN)N)NN)N)__name__ __module__ __qualname__rrrrrrrrr!r"r#rrrrrs(         rN)utilsrrrrrrrrrs