actions/opensearch-pyd
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Added versioning support to *_script APIs

Browse Source
This commit is contained in:
Honza Král
2014-09-08 12:16:08 +02:00
parent 44060a48a0
commit f9b70383b9
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
elasticsearch/client/__init__.py
+10 -3
View File
@@ -1002,7 +1002,7 @@ class Elasticsearch(object):
doc_type, '_bench'), params=params) doc_type, '_bench'), params=params)
return data return data
@query_params() @query_params('op_type', 'version', 'version_type')
def put_script(self, lang, id, body, params=None): def put_script(self, lang, id, body, params=None):
""" """
Create a script in given language with specified ID. Create a script in given language with specified ID.
@@ -1011,12 +1011,15 @@ class Elasticsearch(object):
:arg lang: Script language :arg lang: Script language
:arg id: Script ID :arg id: Script ID
:arg body: The document :arg body: The document
:arg op_type: Explicit operation type, default u'index'
:arg version: Explicit version number for concurrency control
:arg version_type: Specific version type
""" """
_, data = self.transport.perform_request('PUT', _make_path('_scripts', _, data = self.transport.perform_request('PUT', _make_path('_scripts',
lang, id), params=params, body=body) lang, id), params=params, body=body)
return data return data
@query_params() @query_params('version', 'version_type')
def get_script(self, lang, id, params=None): def get_script(self, lang, id, params=None):
""" """
Retrieve a script from the API. Retrieve a script from the API.
@@ -1024,12 +1027,14 @@ class Elasticsearch(object):
:arg lang: Script language :arg lang: Script language
:arg id: Script ID :arg id: Script ID
:arg version: Explicit version number for concurrency control
:arg version_type: Specific version type
""" """
_, data = self.transport.perform_request('GET', _make_path('_scripts', _, data = self.transport.perform_request('GET', _make_path('_scripts',
lang, id), params=params) lang, id), params=params)
return data return data
@query_params() @query_params('version', 'version_type')
def delete_script(self, lang, id, params=None): def delete_script(self, lang, id, params=None):
""" """
Remove a stored script from elasticsearch. Remove a stored script from elasticsearch.
@@ -1037,6 +1042,8 @@ class Elasticsearch(object):
:arg lang: Script language :arg lang: Script language
:arg id: Script ID :arg id: Script ID
:arg version: Explicit version number for concurrency control
:arg version_type: Specific version type
""" """
_, data = self.transport.perform_request('DELETE', _, data = self.transport.perform_request('DELETE',
_make_path('_scripts', lang, id), params=params) _make_path('_scripts', lang, id), params=params)